Modifier and Type | Method and Description |
---|---|
static BrokerClusterPublisher |
BrokerClusterPublisher.newOrReconnect(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,
BrokerConnectionDescriptor mon_desc)
Attempts to create BrokerClusterPublisher.
|
static BrokerClusterPublisher |
BrokerClusterPublisher.reconnect(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,
BrokerConnectionDescriptor mon_desc)
Reconnects BrokerClusterPublisher.
|
Modifier and Type | Method and Description |
---|---|
int |
BrokerCPSelectionCallback.chooseClusterClient(BrokerClusterPublisher bcp,
BrokerEvent[] event,
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,
BrokerInfo[] bi,
java.lang.Object client_data)
Implement this method to select a cluster client to be used for single publish operation.
|
void |
BrokerCPConnectionCallback.handleConnectionChange(BrokerClusterPublisher bcp,
int connect_state,
java.lang.String conn_name,
java.lang.Object client_data)
Implement this method to handle cluster publisher connection callbacks.
|
Constructor and Description |
---|
BrokerEvent(java.lang.String event_type_name,
BrokerClusterPublisher bcp)
Create an event of the appropriate type with an associated client from the BrokerClusterPublisher's cluster pool.
|
BrokerEvent(java.lang.String event_type_name,
BrokerClusterPublisher bcp,
java.lang.Class storage_class)
Deprecated.
As of Java API v6.5.
|
BrokerEvent(java.lang.String event_type_name,
BrokerClusterPublisher bcp,
java.lang.Object storage_object)
Deprecated.
As of Java API v6.5.
|
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.