@Deprecated public class BrokerClient extends Object
| Modifier and Type | Field and Description |
|---|---|
static String |
WSE_EN_IDENTIFIER
Deprecated.
|
static String |
WSE_EVENTING_NS
Deprecated.
|
| Constructor and Description |
|---|
BrokerClient(org.apache.axis2.context.ConfigurationContext configurationContext,
String brokerUrl,
String cookie)
Deprecated.
|
BrokerClient(org.apache.axis2.context.ConfigurationContext configurationContext,
String brokerUrl,
String userName,
String password)
Deprecated.
|
BrokerClient(String brokerUrl)
Deprecated.
|
BrokerClient(String brokerUrl,
String cookie)
Deprecated.
|
BrokerClient(String brokerUrl,
String userName,
String password)
Deprecated.
|
| Modifier and Type | Method and Description |
|---|---|
org.wso2.carbon.event.client.stub.generated.SubscriptionDetails[] |
getAllSubscriptions()
Deprecated.
|
org.wso2.carbon.event.client.stub.generated.GetSubscriptionsResponse |
getAllSubscriptions(int maxRequestCount,
String resultFilter,
int firstIndex)
Deprecated.
|
void |
publish(String topic,
org.apache.axiom.om.OMElement element)
Deprecated.
|
void |
publish(String topic,
String messageContent)
Deprecated.
Publishes a message to a topic.
|
void |
renewSubscription(String subscriptionID,
long time)
Deprecated.
|
String |
subscribe(String topic,
String eventSinkUrl)
Deprecated.
|
String |
subscribe(String topic,
String eventSinkUrl,
long expirationTime,
org.apache.axiom.om.OMElement[] extensions)
Deprecated.
|
void |
unsubscribe(String subscriptionID)
Deprecated.
|
public static final String WSE_EVENTING_NS
public static final String WSE_EN_IDENTIFIER
public BrokerClient(String brokerUrl, String userName, String password) throws org.apache.axis2.AxisFault, org.wso2.carbon.event.client.stub.generated.authentication.AuthenticationExceptionException
org.apache.axis2.AxisFaultorg.wso2.carbon.event.client.stub.generated.authentication.AuthenticationExceptionExceptionpublic BrokerClient(org.apache.axis2.context.ConfigurationContext configurationContext,
String brokerUrl,
String userName,
String password)
throws org.apache.axis2.AxisFault,
org.wso2.carbon.event.client.stub.generated.authentication.AuthenticationExceptionException
org.apache.axis2.AxisFaultorg.wso2.carbon.event.client.stub.generated.authentication.AuthenticationExceptionExceptionpublic BrokerClient(org.apache.axis2.context.ConfigurationContext configurationContext,
String brokerUrl,
String cookie)
public BrokerClient(String brokerUrl)
public String subscribe(String topic, String eventSinkUrl) throws BrokerClientException
BrokerClientExceptionpublic String subscribe(String topic, String eventSinkUrl, long expirationTime, org.apache.axiom.om.OMElement[] extensions) throws BrokerClientException
BrokerClientExceptionpublic void publish(String topic, org.apache.axiom.om.OMElement element) throws org.apache.axis2.AxisFault
org.apache.axis2.AxisFaultpublic void publish(String topic, String messageContent) throws BrokerClientException
topic - The name of the topic which the message should be published.messageContent - The message content.BrokerClientExceptionpublic void unsubscribe(String subscriptionID) throws RemoteException
RemoteExceptionpublic org.wso2.carbon.event.client.stub.generated.GetSubscriptionsResponse getAllSubscriptions(int maxRequestCount,
String resultFilter,
int firstIndex)
throws RemoteException
RemoteExceptionpublic org.wso2.carbon.event.client.stub.generated.SubscriptionDetails[] getAllSubscriptions()
throws RemoteException
RemoteExceptionpublic void renewSubscription(String subscriptionID, long time) throws RemoteException
RemoteExceptionCopyright © 2019 WSO2. All rights reserved.