ds.granules.util

Class StreamPublisher

java.lang.Object

ds.granules.util.StreamPublisher

public class StreamPublisher
extends Object

Constructor Summary

Constructors

Constructor and Description
StreamPublisher() Create a new stream publisher instance.

Method Summary

Methods

Modifier and Type	Method and Description
void	publishToStream(String publishStream, byte[] transferBytes) Utility method that allows a producer to publish a set of bytes onto the specified stream.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

StreamPublisher

public StreamPublisher()

Create a new stream publisher instance.

Method Detail

publishToStream

public void publishToStream(String publishStream,
                   byte[] transferBytes)
                     throws CommunicationsException

Utility method that allows a producer to publish a set of bytes onto the specified stream.

Parameters:

publishStream - Synopsis of the stream to publish to

transferBytes - the payload for the stream fragments

Throws:

CommunicationsException - When communication problems are encountered.