Uses of Class
COM.activesw.api.client.BrokerTransactionalClient

Uses of BrokerTransactionalClient in COM.activesw.api.client

Methods in COM.activesw.api.client that return BrokerTransactionalClient

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.

Methods in COM.activesw.api.client with parameters of type BrokerTransactionalClient

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.