You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@streampipes.apache.org by ze...@apache.org on 2020/04/18 10:13:01 UTC
[incubator-streampipes] branch dev updated: STREAMPIPES-105: Create
Kafka Publisher Sink
This is an automated email from the ASF dual-hosted git repository.
zehnder pushed a commit to branch dev
in repository https://gitbox.apache.org/repos/asf/incubator-streampipes.git
The following commit(s) were added to refs/heads/dev by this push:
new 64f6b27 STREAMPIPES-105: Create Kafka Publisher Sink
64f6b27 is described below
commit 64f6b2714cf9d539f77d8319d5dd69519f2077b6
Author: Philipp Zehnder <ze...@fzi.de>
AuthorDate: Sat Apr 18 12:12:42 2020 +0200
STREAMPIPES-105: Create Kafka Publisher Sink
---
.../java/org/apache/streampipes/messaging/jms/ActiveMQPublisher.java | 3 ++-
1 file changed, 2 insertions(+), 1 deletion(-)
diff --git a/streampipes-messaging-jms/src/main/java/org/apache/streampipes/messaging/jms/ActiveMQPublisher.java b/streampipes-messaging-jms/src/main/java/org/apache/streampipes/messaging/jms/ActiveMQPublisher.java
index e2e251f..db610fc 100644
--- a/streampipes-messaging-jms/src/main/java/org/apache/streampipes/messaging/jms/ActiveMQPublisher.java
+++ b/streampipes-messaging-jms/src/main/java/org/apache/streampipes/messaging/jms/ActiveMQPublisher.java
@@ -92,7 +92,8 @@ public class ActiveMQPublisher implements EventProducer<JmsTransportProtocol> {
this.connection.start();
this.connected = true;
} catch (JMSException e) {
- throw new SpRuntimeException("could not connect to activemq broker");
+ throw new SpRuntimeException("could not connect to activemq broker. Broker: '" +
+ protocolSettings.getBrokerHostname() + "' Port: " + protocolSettings.getPort());
}
}