AMQP Content header payload structure

» development » AMQP Content header payload structure

By : nodusjazz

Date : November 29 2020, 01:01 AM

With these it helps I realize that this is an old post, but since I recently came upon some enlightement on this topic, I'll post my observations here in case others have a need to understand this detail.
I just recently fought this battle while trying to implement the AMQP API for Perl in order to talk to a RabbitMQ server. I also did not find any official documentation regarding this detail. However, the rabbitmq docs have among them the source code for a JAVA API.

code :

Share :

Apache Camel AMQP - ActiveMQ AMQP header mismatch value 1, expecting 0

By : meghana gurram

Date : March 29 2020, 07:55 AM

I wish this help you I was able to get this to work by adding the following mvn dependencies:

code :

    <dependency>
        <groupId>org.apache.camel</groupId>
        <artifactId>camel-amqp</artifactId>
        <version>${camel.version}</version>
    </dependency>
    <dependency>
        <groupId>org.apache.geronimo.specs</groupId>
        <artifactId>geronimo-jms_1.1_spec</artifactId>
        <version>1.0</version>
    </dependency>
    <dependency>
        <groupId>org.apache.qpid</groupId>
        <artifactId>qpid-amqp-1-0-client-jms</artifactId>
        <version>0.24</version>
    </dependency>
    <dependency>
        <groupId>org.apache.qpid</groupId>
        <artifactId>qpid-amqp-1-0-client</artifactId>
        <version>0.24</version>
    </dependency>

<bean id="jmsConnectionFactory" class="org.apache.qpid.amqp_1_0.jms.impl.ConnectionFactoryImpl" factory-method="createFromURL">
<constructor-arg index="0" type="java.lang.String" value="amqp:///?brokerlist='tcp://localhost:5672''" />

AMQP 1.0 Qpid BytesMessage large payload

By : David

Date : March 29 2020, 07:55 AM

fixed the issue. Will look into that further So you have basically landed on every deprecated bit of AMQP software I know of so I would guess that your issue comes from one of the old and unmaintained pieces of software.
ActiveMQ Apollo has been deprecated an unmaintained for several years now, instead you should use ActiveMQ Artemis which is the most active broker in the ActiveMQ project.

ruby rest-client content in the header / payload

By : Bruno Meirelles

Date : March 29 2020, 07:55 AM

I wish this helpful for you -d is the data argument in your post request and it has nothing to do with headers.

code :

payload={                                                                        
  version: 'v15',                                                           
}.to_json

Spring WS - Looking for Request header/payload and Response header/payload Example

By : Apophenion

Date : March 29 2020, 07:55 AM

With these it helps I have solved the issue. I can send the SOAP header to a service and extract the response header from response also. No need for interceptors.
Main help was from blog post from Andreas Veithen. .

code :

public class ClientSamaAccountInformation extends WebServiceGatewaySupport {

    public ClientSamaAccountInformation() {
    }

    public FIGetAcctsInfoCallBackRs sendRequest(FIGetAcctsInfoCallBackRq request, MsgHdrRq msgHdrRq) {

        WebServiceTemplate webServiceTemplate =  getWebServiceTemplate();
        try {
            ResponseAndHeader responseAndHeader = webServiceTemplate.sendAndReceive(Constants.WEBSERVICE_URL, 
                new WebServiceMessageCallback() {
                  public void doWithMessage(WebServiceMessage message) throws IOException {
                      try {
                          Jaxb2Marshaller marshallerRq = new Jaxb2Marshaller();
                          marshallerRq.setContextPath("com.abc.domain..getacctinfo");

                          marshallerRq.afterPropertiesSet();

                          MarshallingUtils.marshal(marshallerRq, request, message);

                          SoapHeader soapHeader = ((SoapMessage)message).getSoapHeader();
                          JAXBContext context = JAXBContext.newInstance(MsgHdrRq.class);
                          Marshaller marshaller = context.createMarshaller();
                          marshaller.marshal(msgHdrRq, soapHeader.getResult());
                      } catch (Exception e) {
                          e.printStackTrace();
                      }
                  }
                },
                new WebServiceMessageExtractor<ResponseAndHeader>() {
                  public ResponseAndHeader extractData(WebServiceMessage message) throws IOException {

                    //Extract response payload
                    FIGetAcctsInfoCallBackRs response = null;
                    try {
                        Jaxb2Marshaller marshallerRs = new Jaxb2Marshaller();
                        marshallerRs.setContextPath("com.abc.domain..getacctinfo");
                        marshallerRs.afterPropertiesSet();
                        response = (FIGetAcctsInfoCallBackRs) MarshallingUtils.unmarshal(marshallerRs, message);

                    } catch (Exception e) {
                        e.printStackTrace();
                    }

                    //Extract response header
                    MsgHdrRs msgHdrRs = null;
                    try {
                        JAXBContext context = JAXBContext.newInstance(MsgHdrRs.class);
                        Unmarshaller unmarshaller = context.createUnmarshaller();

                        SoapHeader header = ((SoapMessage)message).getSoapHeader();
                        Iterator<SoapHeaderElement> it = header.examineHeaderElements(new QName("http://www.abc.def.com/common/Header", "MsgHdrRs"));
                        while(it.hasNext()) {
                            msgHdrRs = (MsgHdrRs) unmarshaller.unmarshal(it.next().getSource());
                            System.out.println(msgHdrRs);

                        }
                    } catch (Exception e) {
                        e.printStackTrace();
                    }

                    return null;
                  }
                });

            return null;
        } catch (Exception e) {
            e.printStackTrace();
            return null;
        }
    }
}

How to use SpEL to read payload and header content in a Spring Integration Router

By : user2566994

Date : March 29 2020, 07:55 AM

To fix this issue Looks like the paylaod is MIComposite not Composite.
In any case, SpEL uses the JavaBean conventions; so isError() is a getter for a boolean property error. So payload.error should work (as long as MIComposite exposes it). Or you can use payload.isError().