Package | Description |
---|---|
COM.activesw.api.client |
Modifier and Type | Method and Description |
---|---|
BrokerEvent[] |
BrokerClient.browseEvents(int from_index,
int max_events,
COM.activesw.api.client.BrokerFilterDescriptor[] filters)
Peek one or more events from the specified client's queue.
|
BrokerEvent[] |
BrokerClient.deliverRequestAndWait(java.lang.String dest_id,
BrokerEvent event,
int msecs)
Deliver one request event and wait for replies.
|
BrokerEvent[] |
BrokerClusterPublisher.deliverRequestAndWait(java.lang.String dest_id,
BrokerEvent event,
int msecs)
Deliver one request event and wait for replies.
|
BrokerEvent[] |
BrokerTransactionalClient.deliverRequestAndWait(java.lang.String dest_id,
BrokerEvent event,
int msecs) |
static BrokerEvent |
BrokerEvent.fromBinData(BrokerClient client,
byte[] data) |
static BrokerEvent |
BrokerEvent.fromBinData(BrokerClient client,
byte[] data,
java.lang.String event_type_name)
Create an event using a byte array given out by toBinData().
|
BrokerEvent |
BrokerClient.getClientInfoset()
Get the infoset for this client.
|
BrokerEvent |
BrokerClusterPublisher.getClusterPublisherInfo()
Get the cluster publisher info.
|
BrokerEvent |
BrokerClusterPublisher.getClusterPublisherStats()
Get the cluster publisher statistics.
|
BrokerEvent |
BrokerClient.getEvent(int msecs)
Gets a single event from this client's queue.
|
BrokerEvent |
BrokerTransactionalClient.getEvent(int msecs)
Gets a single event from this client's queue, that is part of the given open transaction context.
|
protected BrokerEvent |
BrokerClient.getEvent(int msecs,
BrokerTransactionalClient tx_client)
Gets a single event from this client's queue, that is part of the given open transaction context.
|
BrokerEvent |
BrokerEvent.getEventField(java.lang.String field_name)
Get the value of an event field.
|
BrokerEvent[] |
BrokerClient.getEvents(int max_events,
int msecs)
Gets one or more events from this client's queue.
|
BrokerEvent[] |
BrokerTransactionalClient.getEvents(int max_events,
int msecs)
Gets one or more events from this client's queue, that is a part of the the give open transaction context.
|
protected BrokerEvent[] |
BrokerClient.getEvents(int max_events,
int msecs,
BrokerTransactionalClient tx_client)
Gets one or more events from this client's queue, that is a part of the the give open transaction context.
|
BrokerEvent[] |
BrokerClient.getEvents(int max_events,
long seqn,
int msecs)
The sequence number is the event to acknowledge through.
|
BrokerEvent[] |
BrokerTransactionalClient.getEvents(int max_events,
long seqn,
int msecs)
This request gets processed only after the BrokerTransactionalClient is is committed.
|
protected BrokerEvent[] |
BrokerClient.getEvents(int max_events,
long seqn,
int msecs,
BrokerTransactionalClient tx_client)
This request gets processed only after the given BrokerTransactionalClient is is committed.
|
BrokerEvent[] |
BrokerEvent.getEventSeqField(java.lang.String field_name,
int offset,
int max_n)
Get the value of an event sequence field.
|
BrokerEvent |
BrokerClient.getEventTypeInfoset(java.lang.String event_type_name,
java.lang.String infoset_name)
Get the specified infoset for the specified event type.
|
BrokerEvent[] |
BrokerClient.getEventTypeInfosets(java.lang.String event_type_name,
java.lang.String[] infoset_names)
Get the requested infosets for the specified event type.
|
BrokerEvent |
BrokerEvent.getStructFieldAsEvent(java.lang.String field_name)
Get the value of a structure field.
|
BrokerEvent[] |
BrokerEvent.getStructSeqFieldAsEvents(java.lang.String field_name,
int offset,
int max_n)
Get the value of a structure sequence field.
|
BrokerEvent[] |
BrokerClusterPublisher.localPublishRequestAndWait(BrokerEvent event,
int msecs)
Publish one request event and wait for replies.
|
BrokerEvent[] |
BrokerClient.publishRequestAndWait(BrokerEvent event,
int msecs)
Publish one request event to the broker and wait for replies.
|
BrokerEvent[] |
BrokerClusterPublisher.publishRequestAndWait(BrokerEvent event,
int msecs)
Publish one request event and wait for replies.
|
BrokerEvent[] |
BrokerTransactionalClient.publishRequestAndWait(BrokerEvent event,
int msecs) |
BrokerEvent[] |
BrokerClient.resendUnacknowledgedEvents(long[] seqn)
A list of events with the given "seqn" numbers will be sent to the broker again since they had not been acknowledged so far.
|
Modifier and Type | Method and Description |
---|---|
static java.lang.String |
BrokerFormat.assemble(BrokerEvent event,
java.util.Vector tokens)
Assemble a string from the tokens, replacing references with values from the event.
|
static java.lang.String |
BrokerFormat.assemble(BrokerEvent event,
java.util.Vector tokens,
java.util.Locale locale)
Assemble a string from the tokens, replacing references with values from the event.
|
int |
BrokerCPSelectionCallback.chooseClusterClient(BrokerClusterPublisher bcp,
BrokerEvent[] event,
COM.activesw.api.client.BrokerInfo[] bi,
java.lang.Object client_data)
Implement this method to select a cluster client to be used for multi-publish operation.
|
int |
BrokerCPSelectionCallback.chooseClusterClient(BrokerClusterPublisher bcp,
BrokerEvent event,
COM.activesw.api.client.BrokerInfo[] bi,
java.lang.Object client_data)
Implement this method to select a cluster client to be used for single publish operation.
|
void |
BrokerClient.deliver(java.lang.String dest_id,
BrokerEvent event)
Deliver one event.
|
void |
BrokerClusterPublisher.deliver(java.lang.String dest_id,
BrokerEvent event)
Deliver one event.
|
void |
BrokerTransactionalClient.deliver(java.lang.String dest_id,
BrokerEvent event)
Deliver one event in the given transaction.
|
void |
BrokerClient.deliver(java.lang.String dest_id,
BrokerEvent[] events)
Deliver multiple events.
|
void |
BrokerClusterPublisher.deliver(java.lang.String dest_id,
BrokerEvent[] events)
Deliver multiple events.
|
void |
BrokerTransactionalClient.deliver(java.lang.String dest_id,
BrokerEvent[] events)
Deliver multiple events on the given transaction.
|
protected void |
BrokerClient.deliver(java.lang.String dest_id,
BrokerEvent[] events,
BrokerTransactionalClient tx_client)
Deliver multiple events on the given transaction.
|
protected void |
BrokerClient.deliver(java.lang.String dest_id,
BrokerEvent event,
BrokerTransactionalClient tx_client)
Deliver one event in the given transaction.
|
void |
BrokerClient.deliverAckReplyEvent(BrokerEvent request_event,
long publish_seqn)
Delivers an Adapter::ack event to the originator of the specified event, which is most likely a request event.
|
void |
BrokerTransactionalClient.deliverAckReplyEvent(BrokerEvent request_event,
long publish_seqn)
Delivers an Adapter::ack event to the originator of the specified event, which is most likely a request event for given transaction.
|
protected void |
BrokerClient.deliverAckReplyEvent(BrokerEvent request_event,
long publish_seqn,
BrokerTransactionalClient tx_client)
Delivers an Adapter::ack event to the originator of the specified event, which is most likely a request event for given transaction.
|
void |
BrokerClient.deliverErrorReplyEvent(BrokerEvent request_event,
BrokerEvent error_event)
/** Give a single error event to the broker to all be delivered to the client that published the 'request_event'.
|
void |
BrokerTransactionalClient.deliverErrorReplyEvent(BrokerEvent request_event,
BrokerEvent error_event)
Give a single error event to the broker to all be delivered to the client that published the 'request_event' for given transaction.
|
protected void |
BrokerClient.deliverErrorReplyEvent(BrokerEvent request_event,
BrokerEvent error_event,
BrokerTransactionalClient tx_client)
Give a single error event to the broker to all be delivered to the client that published the 'request_event' for given transaction.
|
void |
BrokerClient.deliverNullReplyEvent(BrokerEvent request_event,
java.lang.String reply_event_type_name,
long publish_seqn)
Delivers a null event of type 'reply_event_type_name' to the originator of the specified event, which is most likely a request event.
|
void |
BrokerTransactionalClient.deliverNullReplyEvent(BrokerEvent request_event,
java.lang.String reply_event_type_name,
long publish_seqn)
Delivers a null event of type 'reply_event_type_name' to the originator of the specified event, which is most likely a request event for given
transaction.
|
protected void |
BrokerClient.deliverNullReplyEvent(BrokerEvent request_event,
java.lang.String reply_event_type_name,
long publish_seqn,
BrokerTransactionalClient tx_client)
Delivers a null event of type 'reply_event_type_name' to the originator of the specified event, which is most likely a request event for given
transaction.
|
int |
BrokerClient.deliverPartialReplyEvents(BrokerEvent request_event,
BrokerEvent[] events,
int flag,
int token)
Give multiple events to the broker to all be delivered to the client that published the 'request_event'.
|
int |
BrokerClient.deliverPartialReplyEvents(BrokerEvent request_event,
BrokerEvent[] events,
int flag,
int token)
Give multiple events to the broker to all be delivered to the client that published the 'request_event'.
|
int |
BrokerTransactionalClient.deliverPartialReplyEvents(BrokerEvent request_event,
BrokerEvent[] events,
int flag,
int token)
Give multiple events to the broker to all be delivered to the client that published the 'request_event' for the given transaction.
|
int |
BrokerTransactionalClient.deliverPartialReplyEvents(BrokerEvent request_event,
BrokerEvent[] events,
int flag,
int token)
Give multiple events to the broker to all be delivered to the client that published the 'request_event' for the given transaction.
|
protected int |
BrokerClient.deliverPartialReplyEvents(BrokerEvent request_event,
BrokerEvent[] events,
int flag,
int token,
BrokerTransactionalClient tx_client)
Give multiple events to the broker to all be delivered to the client that published the 'request_event' for the given transaction.
|
protected int |
BrokerClient.deliverPartialReplyEvents(BrokerEvent request_event,
BrokerEvent[] events,
int flag,
int token,
BrokerTransactionalClient tx_client)
Give multiple events to the broker to all be delivered to the client that published the 'request_event' for the given transaction.
|
void |
BrokerClient.deliverReplyEvent(BrokerEvent request_event,
BrokerEvent event)
Give a single event to the broker to all be delivered to the client that published the 'request_event'.
|
void |
BrokerTransactionalClient.deliverReplyEvent(BrokerEvent request_event,
BrokerEvent event)
Give a single event to the broker to all be delivered to the client that published the 'request_event' for the given transaction.
|
protected void |
BrokerClient.deliverReplyEvent(BrokerEvent request_event,
BrokerEvent event,
BrokerTransactionalClient tx_client)
Give a single event to the broker to all be delivered to the client that published the 'request_event' for the given transaction.
|
void |
BrokerClient.deliverReplyEvents(BrokerEvent request_event,
BrokerEvent[] events)
Give multiple events to the broker to all be delivered to the client that published the 'request_event'.
|
void |
BrokerClient.deliverReplyEvents(BrokerEvent request_event,
BrokerEvent[] events)
Give multiple events to the broker to all be delivered to the client that published the 'request_event'.
|
void |
BrokerTransactionalClient.deliverReplyEvents(BrokerEvent request_event,
BrokerEvent[] events)
Give multiple events to the broker to all be delivered to the client that published the 'request_event' for given transaction.
|
void |
BrokerTransactionalClient.deliverReplyEvents(BrokerEvent request_event,
BrokerEvent[] events)
Give multiple events to the broker to all be delivered to the client that published the 'request_event' for given transaction.
|
void |
BrokerClient.deliverReplyEvents(BrokerEvent request_event,
BrokerEvent[] events,
BrokerTransactionalClient tx_client)
Give multiple events to the broker to all be delivered to the client that published the 'request_event' for given transaction.
|
void |
BrokerClient.deliverReplyEvents(BrokerEvent request_event,
BrokerEvent[] events,
BrokerTransactionalClient tx_client)
Give multiple events to the broker to all be delivered to the client that published the 'request_event' for given transaction.
|
BrokerEvent[] |
BrokerClient.deliverRequestAndWait(java.lang.String dest_id,
BrokerEvent event,
int msecs)
Deliver one request event and wait for replies.
|
BrokerEvent[] |
BrokerClusterPublisher.deliverRequestAndWait(java.lang.String dest_id,
BrokerEvent event,
int msecs)
Deliver one request event and wait for replies.
|
BrokerEvent[] |
BrokerTransactionalClient.deliverRequestAndWait(java.lang.String dest_id,
BrokerEvent event,
int msecs) |
void |
BrokerClient.deliverWithAck(java.lang.String dest_id,
BrokerEvent[] events,
int ack_type,
long[] ack_seqn)
Deliver multiple events.
|
void |
BrokerTransactionalClient.deliverWithAck(java.lang.String dest_id,
BrokerEvent[] events,
int ack_type,
long[] ack_seqn)
Deliver multiple events on the given transaction.
|
protected void |
BrokerClient.deliverWithAck(java.lang.String dest_id,
BrokerEvent[] events,
int ack_type,
long[] ack_seqn,
BrokerTransactionalClient tx_client)
Deliver multiple events on the given transaction.
|
java.lang.String |
BrokerFormat.format(BrokerEvent event)
Return formatted string, using
|
java.lang.String |
BrokerFormat.format(BrokerEvent event,
java.util.Locale locale)
Return formatted string, using
|
static java.lang.String |
BrokerFormat.format(BrokerEvent event,
java.lang.String format_string)
Format an event using a format string.
|
static java.lang.String |
BrokerFormat.format(BrokerEvent event,
java.lang.String format_string,
java.util.Locale locale)
Format an event using a format string.
|
boolean |
BrokerCallback.handleBrokerEvent(BrokerClient client,
BrokerEvent event,
java.lang.Object client_data)
Implement this method to handle the Information Broker event callbacks.
|
void |
BrokerLockedClientQueueBrowser.insertEventsAtHead(BrokerEvent[] events)
Insert events in into the queue.
|
void |
BrokerLockedClientQueueBrowser.insertEventsAtTail(BrokerEvent[] events)
Insert events in into the queue.
|
void |
BrokerClusterPublisher.localPublish(BrokerEvent event)
Publish one event to clients on the local broker only.
|
void |
BrokerClusterPublisher.localPublish(BrokerEvent[] events)
Publish multiple events to clients on the local broker only.
|
BrokerEvent[] |
BrokerClusterPublisher.localPublishRequestAndWait(BrokerEvent event,
int msecs)
Publish one request event and wait for replies.
|
boolean |
BrokerFilter.match(BrokerEvent event)
Check if the given event matches the filter.
|
void |
BrokerLockedClientQueueBrowser.modifyEvents(long[] seqns,
BrokerEvent[] events)
Modify events in the queue.
|
void |
BrokerClient.publish(BrokerEvent event)
Publish one event.
|
void |
BrokerClusterPublisher.publish(BrokerEvent event)
Publish one event.
|
void |
BrokerTransactionalClient.publish(BrokerEvent event)
Publish one event with the given transaction id.
|
void |
BrokerClient.publish(BrokerEvent[] events)
Publish multiple events.
|
void |
BrokerClusterPublisher.publish(BrokerEvent[] events)
Publish multiple events.
|
protected void |
BrokerClient.publish(BrokerEvent[] events,
BrokerTransactionalClient tx_client)
Publish multiple events on the given transaction.
|
protected void |
BrokerClient.publish(BrokerEvent event,
BrokerTransactionalClient tx_client)
Publish one event with the given transaction id.
|
BrokerEvent[] |
BrokerClient.publishRequestAndWait(BrokerEvent event,
int msecs)
Publish one request event to the broker and wait for replies.
|
BrokerEvent[] |
BrokerClusterPublisher.publishRequestAndWait(BrokerEvent event,
int msecs)
Publish one request event and wait for replies.
|
BrokerEvent[] |
BrokerTransactionalClient.publishRequestAndWait(BrokerEvent event,
int msecs) |
void |
BrokerClient.publishWithAck(BrokerEvent[] events,
int ack_type,
long[] ack_seqn)
Publish multiple events.
|
void |
BrokerTransactionalClient.publishWithAck(BrokerEvent[] events,
int ack_type,
long[] ack_seqn)
Publish multiple events for the given transaction.
|
protected void |
BrokerClient.publishWithAck(BrokerEvent[] events,
int ack_type,
long[] ack_seqn,
BrokerTransactionalClient tx_client)
Publish multiple events for the given transaction.
|
void |
BrokerClient.setClientInfoset(BrokerEvent infoset)
Set the infoset for this client.
|
void |
BrokerEvent.setEventField(java.lang.String field_name,
BrokerEvent value)
Sets the value of an event field.
|
void |
BrokerEvent.setEventSeqField(java.lang.String field_name,
int src_offset,
int dest_offset,
int n,
BrokerEvent[] value)
Set the value of an event sequence field.
|
void |
BrokerEvent.setStructFieldFromEvent(java.lang.String field_name,
BrokerEvent value)
Sets the value of a structure field.
|
void |
BrokerEvent.setStructSeqFieldFromEvents(java.lang.String field_name,
int src_offset,
int dest_offset,
int n,
BrokerEvent[] value)
Sets the value of a structure sequence field.
|
Constructor and Description |
---|
BrokerEvent(BrokerEvent event)
Copy constructor.
|
Copyright © 2002-2006 webMethods, Inc. Copyright © 2007-2021 Software AG Darmstadt, Germany and/or Software AG USA Inc., Reston, VA, USA, and/or its subsidiaries and/or its affiliates and/or their licensors.