question on QPID header-based routing test

[Das, Kapali Tejeswar]

There was a QPID headers test in
java/client/test/src/org/apache/qpid/headers directory that was later
moved to java/client/src/old_test/java/org/apache/qpid/headers
directory. Could somebody let me know why it was moved to old_test
directory?

 

The reason I am asking is that we wrote a headers demo based on this
test that used to work back in December. But it no longer works now; the
broker does not route the messages to the consumer.

 

Specifically, when I start the consumer (with debug logs), I am seeing
the following log, which indicates that there was a problem while
processing BasicConsumeOk message.

 

/////////////////////////

[java] 2007-02-20 16:07:33,062 DEBUG [AnonymousIoService-8]
state.AMQStateManager (AMQStateManager.java:172) - Looking for state
transition handler for frame class
org.apache.qpid.framing.BasicConsumeOkBody

[java] 2007-02-20 16:07:33,078 DEBUG [AnonymousIoService-8]
state.AMQStateManager (AMQStateManager.java:172) - Looking for state
transition handler for frame class
org.apache.qpid.framing.BasicConsumeOkBody

[java] 2007-02-20 16:07:33,078 DEBUG [AnonymousIoService-8]
state.AMQStateManager (AMQStateManager.java:187) - No state transition
handler defined for receiving frame class
org.apache.qpid.framing.BasicConsumeOkBody Class: 60 Method: 21
consumerTag: 1

[java] 2007-02-20 16:07:33,078 DEBUG [main] client.BasicMessageConsumer
(BasicMessageConsumer.java:227) - Session stopped : Message
listener([EMAIL PROTECTED]) set for destination
headers://test_headers_exchange/test_headers_exchange/?exclusive='true'&
autodelete='true'

/////////////////////////

 

Here's a snippet of the code where I am creating a consumer:

 

//////////////////////////////////

 

    public MessageConsumer createConsumer(Destination source) throws
Exception

    {

 

        FieldTable binding = FieldTableFactory.newFieldTable();

        binding.setString("SF1000", "value");

 

        return _session.createConsumer(

            source,

            AMQSession.DEFAULT_PREFETCH_HIGH_MARK,

            AMQSession.DEFAULT_PREFETCH_LOW_MARK,

            false,

            true,

            null,

            binding

        );

    }

 

//////////////////////////////////

 

I am wondering if the AMQP APIs that define a binding between an
exchange and a consumer have changed.

 

Any feedback is much appreciated.

 

Thanks and regards

Tejeswar