Skip to content

Commit 3bfb5ec

Browse files
authored
Merge pull request #50 from Azure/dev
1.0.0-PREVIEW-1 release
2 parents 9553f2e + 21a0f7a commit 3bfb5ec

Some content is hidden

Large Commits have some content hidden by default. Use the searchbox below for content that may be hidden.

48 files changed

+998
-678
lines changed

README.md

Lines changed: 14 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -6,6 +6,8 @@
66

77
**Please be aware that this library is currently in active development, and is not intended for production**
88

9+
[![Maven Central](https://maven-badges.herokuapp.com/maven-central/com.microsoft.azure/azure-servicebus/badge.svg)](https://maven-badges.herokuapp.com/maven-central/com.microsoft.azure/azure-servicebus)
10+
911
This is the next generation Service Bus Java client library that focuses on Queues & Topics. If you are looking for Event Hubs, follow this [link](https://github.com/azure/azure-event-hubs-java).
1012

1113
Azure Service Bus is an asynchronous messaging cloud platform that enables you to send messages between decoupled systems. Microsoft offers this feature as a service, which means that you do not need to host any of your own hardware in order to use it.
@@ -15,3 +17,15 @@ Refer to [azure.com](https://azure.microsoft.com/services/service-bus/) to learn
1517
## How to provide feedback
1618

1719
See our [Contribution Guidelines](./.github/CONTRIBUTING.md).
20+
21+
## FAQ
22+
23+
### Where can I find examples that use this library?
24+
25+
To get started *sending* messages to Service Bus refer to [Get started sending to Service Bus queues](https://github.com/Azure/azure-service-bus/blob/master/samples/Java/src/main/java/com/microsoft/azure/servicebus/samples/SendSample.java).
26+
27+
To get started *receiving* messages with Service Bus refer to [Get started receiving from Service Bus queues](https://github.com/Azure/azure-service-bus/blob/master/samples/Java/src/main/java/com/microsoft/azure/servicebus/samples/ReceiveSample.java).
28+
29+
### Can I manage Service Bus entities with this library?
30+
31+
The standard way to manage Azure resources is by using [Azure Resource Manager](https://docs.microsoft.com/en-us/azure/azure-resource-manager/resource-group-overview). In order to use functionality that previously existed in the azure-servicebus Java library, there will be a new Java specific library before this library becomes generally available. This will enable use cases that dynamically create/read/update/delete resources, and will be similar to the currently available [.NET management library](https://www.nuget.org/packages/Microsoft.WindowsAzure.Management.ServiceBus/).

azure-servicebus-samples/pom.xml

Lines changed: 0 additions & 45 deletions
This file was deleted.

azure-servicebus-samples/src/main/java/com/microsoft/azure/servicebus/samples/ReceiveSample.java

Lines changed: 0 additions & 53 deletions
This file was deleted.

azure-servicebus-samples/src/main/java/com/microsoft/azure/servicebus/samples/SendSample.java

Lines changed: 0 additions & 40 deletions
This file was deleted.

azure-servicebus/pom.xml

Lines changed: 5 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -26,6 +26,11 @@
2626
<showWarnings>true</showWarnings>
2727
</configuration>
2828
</plugin>
29+
<plugin>
30+
<groupId>org.apache.maven.plugins</groupId>
31+
<artifactId>maven-surefire-plugin</artifactId>
32+
<version>2.20</version>
33+
</plugin>
2934
</plugins>
3035
</build>
3136

azure-servicebus/resources/access.properties.template

Lines changed: 0 additions & 23 deletions
This file was deleted.
Lines changed: 11 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,11 @@
1+
#entity names coming from the deployment template
2+
partitioned.queue.name = partitioned-queue
3+
non.partitioned.queue.name = non-partitioned-queue
4+
session.partitioned.queue.name = partitioned-session-queue
5+
session.non.partitioned.queue.name = non-partitioned-session-queue
6+
partitioned.topic.name = partitioned-topic
7+
non.partitioned.topic.name = non-partitioned-topic
8+
session.partitioned.topic.name = partitioned-session-topic
9+
session.non.partitioned.topic.name = non-partitioned-session-topic
10+
subscription.name = subscription
11+
session.subscription.name = session-subscription

azure-servicebus/src/main/java/com/microsoft/azure/servicebus/BrowsableMessageSession.java

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -45,13 +45,13 @@ public Instant getLockedUntilUtc() {
4545
}
4646

4747
@Override
48-
public int getMessagePrefetchCount()
48+
public int getPrefetchCount()
4949
{
5050
throw new UnsupportedOperationException(INVALID_OPERATION_ERROR_MESSAGE);
5151
}
5252

5353
@Override
54-
public void setMessagePrefetchCount(int prefetchCount) throws ServiceBusException
54+
public void setPrefetchCount(int prefetchCount) throws ServiceBusException
5555
{
5656
throw new UnsupportedOperationException(INVALID_OPERATION_ERROR_MESSAGE);
5757
}

azure-servicebus/src/main/java/com/microsoft/azure/servicebus/ClientFactory.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -6,7 +6,7 @@
66
import com.microsoft.azure.servicebus.primitives.MessagingFactory;
77
import com.microsoft.azure.servicebus.primitives.ServiceBusException;
88

9-
class ClientFactory {
9+
public class ClientFactory {
1010

1111
private static final ReceiveMode DEFAULTRECEIVEMODE = ReceiveMode.PeekLock;
1212

azure-servicebus/src/main/java/com/microsoft/azure/servicebus/IMessageAndSessionPump.java

Lines changed: 4 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -51,4 +51,8 @@ interface IMessageAndSessionPump
5151
CompletableFuture<Void> deadLetterAsync(UUID lockToken, String deadLetterReason, String deadLetterErrorDescription);
5252

5353
CompletableFuture<Void> deadLetterAsync(UUID lockToken, String deadLetterReason, String deadLetterErrorDescription, Map<String, Object> propertiesToModify);
54+
55+
int getPrefetchCount();
56+
57+
void setPrefetchCount(int prefetchCount) throws ServiceBusException;
5458
}

0 commit comments

Comments
 (0)