@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.AxisFault
org.wso2.carbon.event.client.stub.generated.authentication.AuthenticationExceptionException
public 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.AxisFault
org.wso2.carbon.event.client.stub.generated.authentication.AuthenticationExceptionException
public BrokerClient(org.apache.axis2.context.ConfigurationContext configurationContext, String brokerUrl, String cookie)
public BrokerClient(String brokerUrl)
public String subscribe(String topic, String eventSinkUrl) throws BrokerClientException
BrokerClientException
public String subscribe(String topic, String eventSinkUrl, long expirationTime, org.apache.axiom.om.OMElement[] extensions) throws BrokerClientException
BrokerClientException
public void publish(String topic, org.apache.axiom.om.OMElement element) throws org.apache.axis2.AxisFault
org.apache.axis2.AxisFault
public void publish(String topic, String messageContent) throws BrokerClientException
topic
- The name of the topic which the message should be published.messageContent
- The message content.BrokerClientException
public void unsubscribe(String subscriptionID) throws RemoteException
RemoteException
public org.wso2.carbon.event.client.stub.generated.GetSubscriptionsResponse getAllSubscriptions(int maxRequestCount, String resultFilter, int firstIndex) throws RemoteException
RemoteException
public org.wso2.carbon.event.client.stub.generated.SubscriptionDetails[] getAllSubscriptions() throws RemoteException
RemoteException
public void renewSubscription(String subscriptionID, long time) throws RemoteException
RemoteException
Copyright © 2020 WSO2. All rights reserved.