this.connector = connector;
}
@Override
public void processReplyTo(MuleEvent event, MuleMessage returnMessage, Object replyTo) throws MuleException
{
<BUG>AbstractBayeux bayeux = connector.getBayeux();
</BUG>
Channel channel = bayeux.getChannel(replyTo.toString(), false);
if(channel==null)
{

this.connector = connector;
}
@Override
public void processReplyTo(MuleEvent event, MuleMessage returnMessage, Object replyTo) throws MuleException
{
AbstractBayeux bayeux = ((BayeuxAware)connector).getBayeux();
Channel channel = bayeux.getChannel(replyTo.toString(), false);
if(channel==null)
{
