Skip to content

Commit

Permalink
Merge pull request #231 from ayeshLK/admin-client-async
Browse files Browse the repository at this point in the history
Update admin client network calls to work reactively
  • Loading branch information
ayeshLK authored Jun 7, 2024
2 parents aec6d84 + c7b2b96 commit 5b3adf7
Show file tree
Hide file tree
Showing 3 changed files with 589 additions and 370 deletions.
1 change: 1 addition & 0 deletions changelog.md
Original file line number Diff line number Diff line change
Expand Up @@ -10,6 +10,7 @@ and this project adheres to [Semantic Versioning](https://semver.org/spec/v2.0.0
### Changed

- [Implement ASB sender/receiver client actions in a non-blocking way](https://github.com/ballerina-platform/ballerina-library/issues/4982)
- [Improve Azure service bus administrator client actions to work in a non-blocking manner](https://github.com/ballerina-platform/ballerina-library/issues/6603)

## [3.8.0] - 2024-05-31

Expand Down
Original file line number Diff line number Diff line change
@@ -0,0 +1,35 @@
/*
* Copyright (c) 2024, WSO2 LLC. (http://www.wso2.org).
*
* WSO2 LLC. licenses this file to you under the Apache License,
* Version 2.0 (the "License"); you may not use this file except
* in compliance with the License.
* You may obtain a copy of the License at
*
* http://www.apache.org/licenses/LICENSE-2.0
*
* Unless required by applicable law or agreed to in writing,
* software distributed under the License is distributed on an
* "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
* KINDither express or implied. See the License for the
* specific language governing permissions and limitations
* under the License.
*/

package org.ballerinax.asb.admin;

import java.util.concurrent.ThreadFactory;

/**
* A {@link ThreadFactory} object that creates new threads on demand for ASB admin network actions.
*/
public class AdminNetworkThreadFactory implements ThreadFactory {
private final String threadGroupName = "asb-admin-network-thread";

@Override
public Thread newThread(Runnable runnable) {
Thread receiverThread = new Thread(runnable);
receiverThread.setName(threadGroupName);
return receiverThread;
}
}
Loading

0 comments on commit 5b3adf7

Please sign in to comment.