Связь клиента с Mule / ActiveMQ и C ++ Stomp

У меня есть внешний клиент COM STOMP, который отправляет сообщение в очередь

myqueue

и подписывается на тему

mytopic

Поток (плагин Mule в eclipse mars), принимающий сообщение, настраивается, сообщение модифицируется и передается для эхо-ответа:

<jms:activemq-connector name="Active_MQ" specification="1.1" brokerURL="tcp://localhost:61616" validateConnections="true" doc:name="Active MQ"/>

<http:listener-config name="HTTP" host="localhost" port="8081"  doc:name="HTTP Listener Configuration"/>

<flow name="jmsFlow">

<jms:inbound-endpoint  queue="myqueue" connector-ref="Active_MQ" doc:name="JMS">

<jms:transaction action="NONE"/>

</jms:inbound-endpoint>

<logger message="#[string: Logger1 Response: #[payload]]" level="INFO" doc:name="Logger1"/>

<response>

<echo-component doc:name="Echo"/>

</response>

<component class="org.mule.java.JavaClient" doc:name="Java"/>

</flow>

Клиент C ++ STOMP:

static BoostStomp*  stomp_client;
static string       notifications_topic = "mytopic";
static string       registration_queue = "myqueue";
static string       result("");
static int          number = 0;

bool subscription_callback(STOMP::Frame& _frame)
{
number = _frame.body().v.size();
result = _frame.body().c_str();
return(true);
}

//int main(int argc, char *argv[])
int main(int argc, char *argv[])
{
string  stomp_host = "localhost";
int     stomp_port = 61613;

char* msg = argv[0];
int nmbr = 1;
char* mymsg = new char[nmbr];
strncpy(mymsg,msg,nmbr);
mymsg[nmbr] = '\0';
string msgstr = string(mymsg);
try
{
// initiate a new BoostStomp client
stomp_client = new BoostStomp(stomp_host, stomp_port);

// start the client, (by connecting to the STOMP server)
stomp_client->start();//(user, pass);

// subscribe to a channel
stomp_client->subscribe(notifications_topic, (STOMP::pfnOnStompMessage_t) &subscription_callback);

// construct a headermap
STOMP::hdrmap headers;
string body = string("mymessage");

// add an outgoing message to the queue
stomp_client->send(registration_queue, headers, body);

Sleep(10000);
nmbr = number;
strncpy(msg,result.c_str(),nmbr);
msg[nmbr] = '\0';
cout << "return message is " << result.c_str();
result.clear();

Sleep(10000);
stomp_client->unsubscribe(notifications_topic);
Sleep(1000);
stomp_client->stop();
delete stomp_client;
}
catch (std::exception& e)
{
cerr << "Error in BoostStomp: " << e.what() << "\n";
return 1;
}
cout << "Call of test works!" << endl;
return 0;
}

Я не уверен, как отправить измененное сообщение в тему

mytopic

вместо эхо-ответа. Какие-либо предложения?

Возможно, другой вариант — использовать приложение Java, которое реализует отправку STOMP-сообщения:

StompConnection connection = new StompConnection();
connection.open("localhost", 61613);
connection.connect("","");

connection.send("/mytopic", msg.toString());

Получение сообщения с

connection.subscribe("/mytopic", Subscribe.AckModeValues.CLIENT);
StompFrame frame = connection.receive();
System.out.println("JavaClient received message: " + frame.getBody());
connection.disconnect();

работает, но внешний клиент STOMP все еще не получает его. STOMP Cout является:

[12:03:28: 00625D48] BoostStomp:starting...
[12:03:28: 00625D48] BoostStomp:STOMP: Connecting to [::1]:61613...
[12:03:28: 00625D48] BoostStomp:STOMP TCP connection to [::1]:61613 is active
[12:03:28: 00625D48] BoostStomp:Sending CONNECT frame...
[12:03:28: 0062E698] BoostStomp:Worker thread: starting...
[12:03:28: 0062E698] BoostStomp:server supports STOMP version 1.1
waiting for answer
[12:03:29: 0062E698] BoostStomp:Sending SUBSCRIBE frame...
[12:03:29: 0062E698] BoostStomp:Sent!
[12:03:29: 0062E698] BoostStomp:Sending SEND frame...
[12:03:29: 0062E698] BoostStomp:Sent!