public class JMSMessageProcessor extends Object implements org.wso2.carbon.messaging.CarbonMessageProcessor
Constructor and Description |
---|
JMSMessageProcessor(org.wso2.siddhi.core.stream.input.source.SourceEventListener sourceEventListener,
int coreThreadPoolSize) |
Modifier and Type | Method and Description |
---|---|
void |
clear() |
String |
getId() |
boolean |
isEmpty() |
boolean |
receive(org.wso2.carbon.messaging.CarbonMessage carbonMessage,
org.wso2.carbon.messaging.CarbonCallback carbonCallback) |
void |
setClientConnector(org.wso2.carbon.messaging.ClientConnector clientConnector) |
void |
setTransportSender(org.wso2.carbon.messaging.TransportSender transportSender) |
public JMSMessageProcessor(org.wso2.siddhi.core.stream.input.source.SourceEventListener sourceEventListener, int coreThreadPoolSize)
public boolean receive(org.wso2.carbon.messaging.CarbonMessage carbonMessage, org.wso2.carbon.messaging.CarbonCallback carbonCallback) throws Exception
receive
in interface org.wso2.carbon.messaging.CarbonMessageProcessor
Exception
public void setTransportSender(org.wso2.carbon.messaging.TransportSender transportSender)
setTransportSender
in interface org.wso2.carbon.messaging.CarbonMessageProcessor
public void setClientConnector(org.wso2.carbon.messaging.ClientConnector clientConnector)
setClientConnector
in interface org.wso2.carbon.messaging.CarbonMessageProcessor
public String getId()
getId
in interface org.wso2.carbon.messaging.CarbonMessageProcessor
public void clear()
public boolean isEmpty()
Copyright © 2017 WSO2. All rights reserved.