Package com.opengamma.transport.jms

Examples of com.opengamma.transport.jms.JmsByteArrayMessageSender.send()


  protected void handleEntityChanged(final ChangeEvent event) {
    final FudgeMsgEnvelope msg = OpenGammaFudgeContext.getInstance().toFudgeMsg(event);
    s_logger.debug("Sending change message {}", msg);
    final byte[] fudgeMsg = OpenGammaFudgeContext.getInstance().toByteArray(msg.getMessage());
    final JmsByteArrayMessageSender messageSender = new JmsByteArrayMessageSender(getJmsConnector().getTopicName(), getJmsConnector().getJmsTemplateTopic());
    messageSender.send(fudgeMsg);
  }

  @Override
  public void onMessage(Message message) {
    try {
View Full Code Here

TOP
Copyright © 2018 www.massapi.com. All rights reserved.
All source code are property of their respective owners. Java is a trademark of Sun Microsystems, Inc and owned by ORACLE Inc. Contact coftware#gmail.com.