com.pcbsys.nirvana.direct.Topic Class Reference

Object returned from the bind call that enables you to send data, or begin consuming events. More...


Public Member Functions
void	send (String tag, byte[] data) throws ClientTransportException
	Send an nEventProperties and data to the consumers of this topic.
void	send (nEventProperties props, byte[] data) throws ClientTransportException
	Send an nEventProperties and data to the consumers of this topic.
void	startReceiving (TopicListener listener, String filter) throws ClientTransportException
	Start receiving messages from the topic using the specified listener.
void	startReceiving (TopicListener listener) throws ClientTransportException
	Start receiving messages from the topic using the specified listener.

Detailed Description

Object returned from the bind call that enables you to send data, or begin consuming events.

void com.pcbsys.nirvana.direct.Topic.send	(	String	tag,
		byte[]	data
	)			throws ClientTransportException

Send an nEventProperties and data to the consumers of this topic.

Parameters:

	tag	a string tag
	data	the data payload for the event

Exceptions:

ClientTransportException

void com.pcbsys.nirvana.direct.Topic.send	(	nEventProperties	props,
		byte[]	data
	)			throws ClientTransportException

Send an nEventProperties and data to the consumers of this topic.

Parameters:

	props	the nEventProperties object
	data	the data payload for the event

Exceptions:

ClientTransportException

void com.pcbsys.nirvana.direct.Topic.startReceiving	(	TopicListener	listener,
		String	filter
	)			throws ClientTransportException

Start receiving messages from the topic using the specified listener.

Parameters:

	listener	the listener that will receive the callbacks
	filter	the filter used by the subscription to consume a subset of events from the topic

Exceptions:

ClientTransportException

void com.pcbsys.nirvana.direct.Topic.startReceiving ( TopicListener listener ) throws ClientTransportException

Start receiving messages from the topic using the specified listener.

Parameters:

listener

the listener that will receive the callbacks

Exceptions:

ClientTransportException