Modifier and Type | Method and Description |
---|---|
static BrokerTransactionalClient |
BrokerTransactionalClient.newOrReconnectTransactionalClient(java.lang.String broker_host,
java.lang.String broker_name,
java.lang.String client_id,
java.lang.String client_group,
java.lang.String app_name,
BrokerConnectionDescriptor desc)
Attempts to create the transactional client.
|
static BrokerTransactionalClient |
BrokerTransactionalClient.reconnectTransactionalClient(java.lang.String broker_host,
java.lang.String broker_name,
java.lang.String client_id,
BrokerConnectionDescriptor desc)
Reconnects a transactional client.
|
Modifier and Type | Method and Description |
---|---|
static void |
BrokerTransactionalClient.abortAll(BrokerTransactionalClient[] tx_clients)
aborts the given list of open transactions, discarding all work previously performed, and invalidates the context.
|
static void |
BrokerTransactionalClient.abortAll(BrokerTransactionalClient[] tx_clients,
java.lang.String external_id)
aborts all the transactions known to this broker with the given external_id Discarding all work previously performed, This method is used in distributed
transactions.
|
static void |
BrokerTransactionalClient.commitAll(BrokerTransactionalClient[] tx_clients)
commits the given list of open transaction.
|
static void |
BrokerTransactionalClient.commitAll(BrokerTransactionalClient[] tx_clients,
java.lang.String external_id)
commits all the open transaction with the given external_id.
|
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.
|
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.
|
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.
|
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.
|
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 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,
BrokerTransactionalClient tx_client)
Give multiple events to the broker to all be delivered to the client that published the 'request_event' for 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.
|
static void |
BrokerTransactionalClient.endAll(BrokerTransactionalClient[] tx_clients,
int end_state) |
static void |
BrokerTransactionalClient.endAll(BrokerTransactionalClient[] tx_clients,
java.lang.String externalId,
int end_state)
Ends the given list of current transactions.
|
static void |
BrokerTransactionalClient.forgetAll(BrokerTransactionalClient[] tx_clients,
java.lang.String external_id)
Forget the transaction with the specified external_id in the given list of transactional clients.
|
static void |
BrokerTransactionalClient.forgetAll(BrokerTransactionalClient tx_client,
java.lang.String[] external_ids)
Forget the transaction with the specified external_id in the given list of transactional clients.
|
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.
|
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.
|
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.
|
protected COM.activesw.api.client.BrokerJMSEvent[] |
BrokerClient.getJMSEvents(int max_events,
long seqn,
int msecs,
BrokerTransactionalClient tx_client) |
protected void |
BrokerClient.jmsClientPublish(COM.activesw.api.client.BrokerJMSEvent[] events,
boolean async,
BrokerTransactionalClient tx_client) |
static void |
BrokerTransactionalClient.prepareAll(BrokerTransactionalClient[] tx_clients,
java.lang.String external_id)
Prepare the specified transaction for commit.
|
static void |
BrokerTransactionalClient.prepareAll(BrokerTransactionalClient tx_client,
java.lang.String[] external_ids)
Prepare the specified list of transactions for commit.
|
protected void |
BrokerClient.prime(int num,
BrokerTransactionalClient tx_client) |
protected void |
BrokerClient.primeWithAck(int num,
BrokerTransactionalClient tx_client) |
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.
|
protected void |
BrokerClient.publishWithAck(BrokerEvent[] events,
int ack_type,
long[] ack_seqn,
BrokerTransactionalClient tx_client)
Publish multiple events for the given transaction.
|
static void |
BrokerTransactionalClient.resumeAll(BrokerTransactionalClient[] tx_clients,
java.lang.String external_id)
Resume the given list of suspended transactions.
|
static void |
BrokerTransactionalClient.suspendAll(BrokerTransactionalClient[] tx_clients,
java.lang.String external_id)
Suspend the given list of current transactions.
|
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.