private static void sendCoreMessage() throws Exception
  {
    // The remote server running HornetQ Version 2.3.15
    Map<String, Object> map = new HashMap<String, Object>();
    map.put("host", "etmeba01");
    map.put("port", 5445);

    System.out.println("Start");
    ServerLocator serverLocator = HornetQClient.createServerLocatorWithoutHA(new TransportConfiguration(NettyConnectorFactory.class.getName(),map));
    System.out.println("serverLocator created");

    ClientSessionFactory sf = serverLocator.createSessionFactory();
    System.out.println("SessionFactory created");

    ClientSession coreSession = sf.createSession(false, false, false);
    final String queueName = "queue.exampleQueue";
    coreSession.createQueue(queueName, queueName, true);
    coreSession.close();
    ClientSession session = null;
    System.out.println("Session created");
    try
    {

       session = sf.createSession();

       ClientProducer producer = session.createProducer(queueName);

       ClientMessage message = session.createMessage(false);
       final String propName = "myprop";
       message.putStringProperty(propName, "Hello HornetQ - " + new Date());

       System.out.println("Sending the message.");
       producer.send(message);

       ClientConsumer messageConsumer = session.createConsumer(queueName);
       session.start();

       ClientMessage messageReceived = messageConsumer.receive(1000);
       System.out.println("Received TextMessage:" + messageReceived.getStringProperty(propName));
    }
    finally
    {
       if (sf != null)
       {
          sf.close();
       }
    }

  }