Package COM.activesw.api.client
Class BrokerLockedClientQueueBrowser
- java.lang.Object
-
- COM.activesw.api.client.BrokerQueueBrowserImpl
-
- COM.activesw.api.client.BrokerClientQueueBrowser
-
- COM.activesw.api.client.BrokerLockedClientQueueBrowser
-
- All Implemented Interfaces:
BrokerLockedQueueBrowser
,BrokerQueueBrowser
public class BrokerLockedClientQueueBrowser extends BrokerClientQueueBrowser implements BrokerLockedQueueBrowser
This class provides queue browsing capabilities to view and modify events of a client queue.
-
-
Field Summary
-
Fields inherited from class COM.activesw.api.client.BrokerQueueBrowserImpl
client, info
-
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description int
deleteEvents(long[] seqns)
Delete events in the queue.void
insertEventsAtHead(BrokerEvent[] events)
Insert events in into the queue.void
insertEventsAtTail(BrokerEvent[] events)
Insert events in into the queue.void
modifyEvents(long[] seqns, BrokerEvent[] events)
Modify events in the queue.-
Methods inherited from class COM.activesw.api.client.BrokerClientQueueBrowser
createException, getBrowserInfo
-
Methods inherited from class COM.activesw.api.client.BrokerQueueBrowserImpl
browseEvents, closeQueueBrowser, getFilters, resetFilters, setFilter, setFilters, setPosition
-
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
-
Methods inherited from interface COM.activesw.api.client.BrokerQueueBrowser
browseEvents, closeQueueBrowser, getBrowserInfo, getFilters, resetFilters, setFilter, setFilters, setPosition
-
-
-
-
Method Detail
-
modifyEvents
public void modifyEvents(long[] seqns, BrokerEvent[] events) throws BrokerException
Modify events in the queue. The events are identified by the specified receipt sequence numbers for an in-place update in the queue.- Specified by:
modifyEvents
in interfaceBrokerLockedQueueBrowser
- Parameters:
seqns
- An array of sequence numbers that identify the events to be modified in the queue.events
- An array of BrokerEvent that will be updated in place of the events in the queue.- Throws:
BrokerInvalidClientException
- If the client has been destroyed or disconnected.BrokerQueueBrowserException
- If the event cannot be modifiedBrokerInvalidClientException
- If the client has been destroyed or disconnected.BrokerQueueBrowserException
- If the event cannot be modifiedBrokerException
-
deleteEvents
public int deleteEvents(long[] seqns) throws BrokerException
Delete events in the queue. The events are identified by their receipt sequence numbers.- Specified by:
deleteEvents
in interfaceBrokerLockedQueueBrowser
- Parameters:
seqns
- An array of sequence numbers that identify the events in the queue.- Returns:
- The number of events deleted from the queue.
- Throws:
BrokerInvalidClientException
- If the client has been destroyed or disconnected.BrokerQueueBrowserException
- If the event cannot be deletedBrokerInvalidClientException
- If the client has been destroyed or disconnected.BrokerQueueBrowserException
- If the event cannot be deletedBrokerException
-
insertEventsAtHead
public void insertEventsAtHead(BrokerEvent[] events) throws BrokerException
Insert events in into the queue. The specified events will be inserted at the head of the queue.- Specified by:
insertEventsAtHead
in interfaceBrokerLockedQueueBrowser
- Parameters:
events
- An array of events to be inserted.- Throws:
BrokerInvalidClientException
- If the client has been destroyed or disconnected.BrokerQueueBrowserException
- If the event cannot be insertedBrokerInvalidClientException
- If the client has been destroyed or disconnected.BrokerQueueBrowserException
- If the event cannot be insertedBrokerException
-
insertEventsAtTail
public void insertEventsAtTail(BrokerEvent[] events) throws BrokerException
Insert events in into the queue. The specified events will be inserted at the end of the queue.- Specified by:
insertEventsAtTail
in interfaceBrokerLockedQueueBrowser
- Parameters:
events
- An array of events to be inserted.- Throws:
BrokerInvalidClientException
- If the client has been destroyed or disconnected.BrokerQueueBrowserException
- If the event cannot be insertedBrokerInvalidClientException
- If the client has been destroyed or disconnected.BrokerQueueBrowserException
- If the event cannot be insertedBrokerException
-
-