- com
- pcbsys
- nirvana
- nJMS
- MessageConsumerImpl
<Enter Class Description> More...
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... | |
![]() | |
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... | |
<Enter Class Description>
void com.pcbsys.nirvana.nJMS.MessageConsumerImpl.close | ( | ) | throws javax.jms.JMSException |
<Enter Method Description>
JMSException | <Enter Exception Description> |
javax.jms.MessageListener com.pcbsys.nirvana.nJMS.MessageConsumerImpl.getMessageListener | ( | ) | throws javax.jms.JMSException |
<Enter Method Description>
JMSException | <Enter Exception Description> |
String com.pcbsys.nirvana.nJMS.MessageConsumerImpl.getMessageSelector | ( | ) | throws javax.jms.JMSException |
<Enter Method Description>
JMSException | <Enter Exception Description> |
void com.pcbsys.nirvana.nJMS.MessageConsumerImpl.go | ( | nConsumeEvent | evt | ) |
<Enter Method Description>
evt | <Enter Parameter Description> |
javax.jms.Message com.pcbsys.nirvana.nJMS.MessageConsumerImpl.receive | ( | ) | throws javax.jms.JMSException |
<Enter Method Description>
JMSException | <Enter Exception Description> |
javax.jms.Message com.pcbsys.nirvana.nJMS.MessageConsumerImpl.receive | ( | long | timeOut | ) | throws javax.jms.JMSException |
<Enter Method Description>
timeOut | <Enter Parameter Description> |
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.
listToPopulateCache | the list, which will be filled up with all the cached events. Will be cleared before use. |
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. |
|
protected |
<Enter Method Description> Clean's up the MessageConsumer resources
JMSException | <Enter Exception Description> |