com.pcbsys.nirvana.nJMS.MessageConsumerImpl Class Reference

<Enter Class Description> More...

Inheritance diagram for com.pcbsys.nirvana.nJMS.MessageConsumerImpl:

Public Member Functions
void	close () throws javax.jms.JMSException
	<Enter Method Description> More...
javax.jms.MessageListener	getMessageListener () throws javax.jms.JMSException
	<Enter Method Description> More...
String	getMessageSelector () throws javax.jms.JMSException
	<Enter Method Description> More...
void	go (nConsumeEvent evt)
	<Enter Method Description> More...
	MessageConsumerImpl (SessionImpl session)
	<Enter Constructor Description>
javax.jms.Message	receive () throws javax.jms.JMSException
	<Enter Method Description> More...
javax.jms.Message	receive (long timeOut) throws javax.jms.JMSException
	<Enter Method Description> More...
int	receiveCacheReturnOutstandingRequests (List< Message > listToPopulateCache) throws JMSException
	This method will return the number of outstanding receive client requests, sent to the server, while also filling up the provided list with all the client-side cached events. More...
Public Member Functions inherited from com.pcbsys.nirvana.client.nEventListener
void	go (com.pcbsys.nirvana.client.nConsumeEvent evt)
	This method is asynchronously called by the nirvana client API to deliver an event to a registered subscriber. More...

Protected Member Functions
void	resetMessageListener () throws javax.jms.JMSException
	<Enter Method Description> Clean's up the MessageConsumer resources More...

Detailed Description

<Enter Class Description>

Member Function Documentation

void com.pcbsys.nirvana.nJMS.MessageConsumerImpl.close

(

)

throws javax.jms.JMSException

<Enter Method Description>

Exceptions

JMSException

<Enter Exception Description>

javax.jms.MessageListener com.pcbsys.nirvana.nJMS.MessageConsumerImpl.getMessageListener

(

)

throws javax.jms.JMSException

<Enter Method Description>

Returns

<Enter Result Description>

Exceptions

JMSException

<Enter Exception Description>

String com.pcbsys.nirvana.nJMS.MessageConsumerImpl.getMessageSelector

(

)

throws javax.jms.JMSException

<Enter Method Description>

Returns

<Enter Result Description>

Exceptions

JMSException

<Enter Exception Description>

void com.pcbsys.nirvana.nJMS.MessageConsumerImpl.go

(

nConsumeEvent

evt

)

<Enter Method Description>

Parameters

evt	<Enter Parameter Description>

javax.jms.Message com.pcbsys.nirvana.nJMS.MessageConsumerImpl.receive

(

)

throws javax.jms.JMSException

<Enter Method Description>

Returns

<Enter Result Description>

Exceptions

JMSException

<Enter Exception Description>

javax.jms.Message com.pcbsys.nirvana.nJMS.MessageConsumerImpl.receive

(

long

timeOut

)

throws javax.jms.JMSException

<Enter Method Description>

Parameters

timeOut

<Enter Parameter Description>

Returns

<Enter Result Description>

Exceptions

JMSException

<Enter Exception Description>

int com.pcbsys.nirvana.nJMS.MessageConsumerImpl.receiveCacheReturnOutstandingRequests

(

List< Message >

listToPopulateCache

)

throws JMSException

This method will return the number of outstanding receive client requests, sent to the server, while also filling up the provided list with all the client-side cached events.

If the provided list is null, no cached events will be extracted. The outstanding requests value is only relevant in horizontal scalability landscape. When sync consumer tries to get an event, if there are none cached, then an iterate/pop request is sent to all of the nodes in the HS landscape. Outstanding are those requests, for which the client is still waiting for the response.

Parameters

listToPopulateCache

the list, which will be filled up with all the cached events. Will be cleared before use.

Returns

number of outstanding queue pop / channel iterate client requests

Exceptions

JMSException

if the consumer is closed or if an event is received, that is not convertible to a JMS Message. If the consumer is closed, the exception will be instance of javax.jms.IllegalStateException.

void com.pcbsys.nirvana.nJMS.MessageConsumerImpl.resetMessageListener ( ) throws javax.jms.JMSException

protected

<Enter Method Description> Clean's up the MessageConsumer resources

Exceptions

JMSException

<Enter Exception Description>