/* * * Licensed to the Apache Software Foundation (ASF) under one * or more contributor license agreements. See the NOTICE file * distributed with this work for additional information * regarding copyright ownership. The ASF licenses this file * to you under the Apache License, Version 2.0 (the * "License"); you may not use this file except in compliance * with the License. You may obtain a copy of the License at * * http://www.apache.org/licenses/LICENSE-2.0 * * Unless required by applicable law or agreed to in writing, * software distributed under the License is distributed on an * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY * KIND, either express or implied. See the License for the * specific language governing permissions and limitations * under the License. * */ #include #include "TestOptions.h" #include "qpid/client/Connection.h" #include "qpid/client/Message.h" #include "qpid/client/Session.h" #include "qpid/client/SubscriptionManager.h" using namespace qpid; using namespace qpid::client; using namespace std; int main(int argc, char** argv) { TestOptions opts; try { opts.parse(argc, argv); Connection connection; connection.open(opts.con); Session session = connection.newSession(); std::string q("header_interop_test_queue"); session.queueDeclare(arg::queue=q); double pi = 3.14159265; float e = 2.71828f; Message msg("", q); msg.getMessageProperties().getApplicationHeaders().setDouble("pi", pi); msg.getMessageProperties().getApplicationHeaders().setFloat("e", e); session.messageTransfer(arg::content=msg); session.close(); connection.close(); return 0; } catch(const exception& e) { cout << e.what() << endl; } return 1; }