final FieldTable ft = FieldTableFactory.newFieldTable();
// if (rawSelector != null)
// ft.put("headers", rawSelector.getDataAsBytes());
if (rawSelector != null)
{
ft.addAll(rawSelector);
}
BasicMessageConsumer consumer =
new BasicMessageConsumer(_channelId, _connection, amqd, messageSelector, noLocal,
_messageFactoryRegistry, AMQSession.this, protocolHandler, ft, prefetchHigh, prefetchLow,