public class MQTTEventAdapter extends Object implements org.wso2.carbon.event.input.adapter.core.InputEventAdapter
| Constructor and Description |
|---|
MQTTEventAdapter(org.wso2.carbon.event.input.adapter.core.InputEventAdapterConfiguration eventAdapterConfiguration,
Map<String,String> globalProperties) |
| Modifier and Type | Method and Description |
|---|---|
void |
connect() |
void |
destroy() |
void |
disconnect() |
boolean |
equals(Object o) |
int |
hashCode() |
void |
init(org.wso2.carbon.event.input.adapter.core.InputEventAdapterListener eventAdapterListener) |
boolean |
isEventDuplicatedInCluster() |
boolean |
isPolling() |
void |
testConnect() |
public void init(org.wso2.carbon.event.input.adapter.core.InputEventAdapterListener eventAdapterListener)
throws org.wso2.carbon.event.input.adapter.core.exception.InputEventAdapterException
init in interface org.wso2.carbon.event.input.adapter.core.InputEventAdapterorg.wso2.carbon.event.input.adapter.core.exception.InputEventAdapterExceptionpublic void testConnect()
throws org.wso2.carbon.event.input.adapter.core.exception.TestConnectionNotSupportedException
testConnect in interface org.wso2.carbon.event.input.adapter.core.InputEventAdapterorg.wso2.carbon.event.input.adapter.core.exception.TestConnectionNotSupportedExceptionpublic void connect()
connect in interface org.wso2.carbon.event.input.adapter.core.InputEventAdapterpublic void disconnect()
disconnect in interface org.wso2.carbon.event.input.adapter.core.InputEventAdapterpublic void destroy()
destroy in interface org.wso2.carbon.event.input.adapter.core.InputEventAdapterpublic boolean isEventDuplicatedInCluster()
isEventDuplicatedInCluster in interface org.wso2.carbon.event.input.adapter.core.InputEventAdapterpublic boolean isPolling()
isPolling in interface org.wso2.carbon.event.input.adapter.core.InputEventAdapterCopyright © 2017 WSO2. All rights reserved.