Class Publisher
- java.lang.Object
-
- de.unistuttgart.isw.sfsc.commonjava.patterns.pubsub.Publisher
-
- All Implemented Interfaces:
NotThrowingAutoCloseable,AutoCloseable
public final class Publisher extends Object implements NotThrowingAutoCloseable
-
-
Constructor Summary
Constructors Constructor Description Publisher(PubSubConnection pubSubConnection)
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description voidclose()voidpublish(byte[] topic, byte[] data)voidpublish(byte[] topic, com.google.protobuf.Message data)voidpublish(com.google.protobuf.ByteString topic, byte[] data)voidpublish(com.google.protobuf.ByteString topic, com.google.protobuf.Message data)voidpublish(String topic, byte[] data)voidpublish(String topic, com.google.protobuf.Message data)
-
-
-
Constructor Detail
-
Publisher
public Publisher(PubSubConnection pubSubConnection)
-
-
Method Detail
-
publish
public void publish(byte[] topic, byte[] data)
-
publish
public void publish(com.google.protobuf.ByteString topic, byte[] data)
-
publish
public void publish(String topic, byte[] data)
-
publish
public void publish(byte[] topic, com.google.protobuf.Message data)
-
publish
public void publish(com.google.protobuf.ByteString topic, com.google.protobuf.Message data)
-
publish
public void publish(String topic, com.google.protobuf.Message data)
-
close
public void close()
- Specified by:
closein interfaceAutoCloseable- Specified by:
closein interfaceNotThrowingAutoCloseable
-
-