|
SonicMQ API | ||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES All Classes | ||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
public interface SonicOutputStreamController
A sonicOutputStreamController object is used to create instances of SonicStream
objects, and to receive data via those stream instances. The stream controller object is
also used to send notification messages from consumersof SonicStream
objects
back to the sender.
Method Summary | |
---|---|
void |
close()
Closes current stream managed by this controller instance, JMS objects created by this controller instance, and the controller itself. |
SonicStream |
createStream(java.lang.String id)
Creates SonicOutputStream instance with the specified ID. |
StreamStatus |
getCurrentStreamStatus()
Returns current SonicOutputStream status as instance of StreamStatus . |
Destination |
getNotificationDestination()
Returns the default JMS destination to which this SonicInputStreamController
instance sends notifications. |
Destination |
getStreamDestination()
Returns JMS destination to which stream contents are written. |
void |
registerExceptionListener(SonicStreamExceptionListener list)
Registers a listener that will receive notification of asynchronous exceptions. |
void |
registerNotificationListener(SonicStreamListener list)
Registers a listener that will receive notifications from receivers. |
void |
releaseStream(SonicStream ss)
Closes the given SonicStream instance and releases its associated resources. |
Method Detail |
---|
void registerExceptionListener(SonicStreamExceptionListener list)
Only a single listener may be registered at a given time.
If this method is invoked multiple times, with a different SonicStreamExceptionListener
reference each time, only the listener specified in the last invocation of this method
will receive exceptions.
list
- reference to a SonicStreamExceptionListener instanceSonicStreamExceptionListener
void registerNotificationListener(SonicStreamListener list)
Only a single listener may be registered at a given time.
If this method is invoked multiple times, with a different SonicStreamListener
reference each time, only the listener specified in the last invocation of this method
will receive notifications.
list
- reference to a SonicStreamListener instanceSonicStreamListener
SonicStream createStream(java.lang.String id) throws SonicStreamException
SonicOutputStream
instance with the specified ID.
The ID will be included in the header of every message sent via the stream.
id
- identifier to be associated with stream instance
SonicStreamException
void releaseStream(SonicStream ss) throws SonicStreamException
SonicStream
instance and releases its associated resources.
ss
- reference to SonicStream instance to close
SonicStreamException
void close() throws SonicStreamException
SonicStreamException
StreamStatus getCurrentStreamStatus()
SonicOutputStream
status as instance of StreamStatus
.
StreamStatus
Destination getNotificationDestination()
SonicInputStreamController
instance sends notifications.
javax.jms.Destination
Destination getStreamDestination()
javax.jms.Destination
|
SonicMQ API | ||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES All Classes | ||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |