Package COM.activesw.api.client

Class BrokerLockedForwardQueueBrowser

java.lang.Object

COM.activesw.api.client.BrokerQueueBrowserImpl

COM.activesw.api.client.BrokerForwardQueueBrowser

COM.activesw.api.client.BrokerLockedForwardQueueBrowser

All Implemented Interfaces:

BrokerLockedQueueBrowser, BrokerQueueBrowser

public class BrokerLockedForwardQueueBrowser
extends BrokerForwardQueueBrowser
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

Modifier and Type	Method	Description
int	deleteEvents(long[] seqns)	Delete events in the queue.
void	insertEventsAtHead(BrokerEvent[] events)	Throws an UnsupportedOperationException.
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.BrokerForwardQueueBrowser

createException

Methods inherited from class COM.activesw.api.client.BrokerQueueBrowserImpl

browseEvents, closeQueueBrowser, getBrowserInfo, 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 interface BrokerLockedQueueBrowser

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 modified

BrokerInvalidClientException - If the client has been destroyed or disconnected.

BrokerQueueBrowserException - If the event cannot be modified

BrokerException

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 interface BrokerLockedQueueBrowser

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 deleted

BrokerInvalidClientException - If the client has been destroyed or disconnected.

BrokerQueueBrowserException - If the event cannot be deleted

BrokerException

insertEventsAtHead

public void insertEventsAtHead(BrokerEvent[] events)
                        throws BrokerException

Throws an UnsupportedOperationException.

Specified by:

insertEventsAtHead in interface BrokerLockedQueueBrowser

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 inserted

BrokerException

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 interface BrokerLockedQueueBrowser

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 inserted

BrokerInvalidClientException - If the client has been destroyed or disconnected.

BrokerQueueBrowserException - If the event cannot be inserted

BrokerException