Rename spring-cloud-azure-eventhub into spring-integration-azure
This commit is contained in:
Родитель
e9d03bc67e
Коммит
e1ac003031
2
pom.xml
2
pom.xml
|
@ -19,7 +19,7 @@
|
|||
<modules>
|
||||
<module>spring-cloud-azure-context</module>
|
||||
<module>spring-cloud-azure-autoconfigure</module>
|
||||
<module>spring-cloud-azure-eventhub</module>
|
||||
<module>spring-integration-azure</module>
|
||||
<module>spring-cloud-azure-storage</module>
|
||||
<module>spring-cloud-azure-eventhub-stream-binder</module>
|
||||
<module>spring-cloud-azure-samples</module>
|
||||
|
|
|
@ -25,7 +25,7 @@
|
|||
|
||||
<dependency>
|
||||
<groupId>com.microsoft.azure</groupId>
|
||||
<artifactId>spring-cloud-azure-eventhub</artifactId>
|
||||
<artifactId>spring-integration-azure</artifactId>
|
||||
<version>${project.version}</version>
|
||||
</dependency>
|
||||
|
||||
|
|
|
@ -9,9 +9,8 @@
|
|||
<relativePath>../pom.xml</relativePath>
|
||||
</parent>
|
||||
|
||||
<artifactId>spring-cloud-azure-eventhub</artifactId>
|
||||
<name>Spring Cloud Azure Event hub</name>
|
||||
<description>Spring Cloud Azure Event hub Module</description>
|
||||
<artifactId>spring-integration-azure</artifactId>
|
||||
<name>Spring Integration Azure</name>
|
||||
|
||||
<dependencies>
|
||||
<dependency>
|
|
@ -83,7 +83,8 @@ public class EventHubTemplate implements EventHubOperation {
|
|||
}
|
||||
|
||||
@Override
|
||||
public synchronized boolean subscribe(String destination, Consumer<Iterable<EventData>> consumer, String consumerGroup) {
|
||||
public synchronized boolean subscribe(String destination, Consumer<Iterable<EventData>> consumer,
|
||||
String consumerGroup) {
|
||||
Tuple<String, String> nameAndConsumerGroup = new Tuple<>(destination, consumerGroup);
|
||||
consumersByNameAndConsumerGroup.putIfAbsent(nameAndConsumerGroup, new CopyOnWriteArraySet<>());
|
||||
boolean added = consumersByNameAndConsumerGroup.get(nameAndConsumerGroup).add(consumer);
|
||||
|
@ -129,7 +130,8 @@ public class EventHubTemplate implements EventHubOperation {
|
|||
}
|
||||
|
||||
@Override
|
||||
public synchronized boolean unsubscribe(String destination, Consumer<Iterable<EventData>> consumer, String consumerGroup) {
|
||||
public synchronized boolean unsubscribe(String destination, Consumer<Iterable<EventData>> consumer,
|
||||
String consumerGroup) {
|
||||
Tuple<String, String> nameAndConsumerGroup = new Tuple<>(destination, consumerGroup);
|
||||
boolean existed = consumersByNameAndConsumerGroup.get(nameAndConsumerGroup).remove(consumer);
|
||||
if (consumersByNameAndConsumerGroup.get(nameAndConsumerGroup).isEmpty()) {
|
Загрузка…
Ссылка в новой задаче