Problem mit javax.jms

  • Problem mit javax.jms

    Guten Abend liebe Community,

    ich wurde damit konfrontiert einen Java Messaging Service zu implementieren. Keine Angst, es ist nur eine Aufgabe für die Hochschule ;)
    Wir haben dazu ein paar Code-Fetzen bekommen. Ich habe nun Java Message Queue 4.3 installiert und einen Broker angelegt. Ich versuche nun mit einem kleinen Producer-Programm eine Nachricht hineinzuschreiben. Jedoch weiß ich nicht, welche Eigenschaften ich für den InitialContext angeben muss. Ich konnte auch in der Doku nicht besonders viel finden.
    Vielleicht hat hier jemand eine Idee?

    Quellcode

    1. import javax.jms.*;
    2. import javax.naming.*;
    3. import java.util.Properties;
    5. public class Producer {
    7. private QueueConnectionFactory qFactory = null;
    8. private QueueConnection qConnect = null;
    9. private QueueSession qSession = null;
    10. private Queue sQueue = null;
    11. private QueueSender qSender = null;
    12. private String username = null;
    13. private String password = null;
    15. /* Constructor. Establish the Producer */
    16. public Producer(String broker, String username, String password) throws Exception {
    17. // Obtain a JNDI connection
    18. Properties env = new Properties();
    19. env.put("java.naming.factory.initial","com.sun.jndi.fscontext.RefFSContextFactory");
    20. env.put("java.naming.provider.url", "localhost:7676");
    21. env.put("java.naming.factory.url.pkgs", "org.jboss.naming:org.jnp.interfaces");
    22. // ... specify the JNDI properties sprecific to the
    23. // provider
    24. InitialContext jndi = new InitialContext(env);
    25. this.username = username;
    26. this.password = password;
    28. // Look up a JMS QueueConnectionFactory
    29. qFactory = (QueueConnectionFactory) jndi.lookup(broker);
    31. // Create a JMS QueueConnection object
    32. qConnect = qFactory.createQueueConnection(username, password);
    34. // Create one JMS QueueSession object
    35. qSession = qConnect.createQueueSession(false,Session.AUTO_ACKNOWLEDGE);
    37. // Look up for a JMS Queue hello
    38. sQueue = (Queue) jndi.lookup("hello");
    40. // Create a sender
    41. qSender = qSession.createSender(sQueue);
    43. // Start the Connection
    44. qConnect.start();
    45. }
    47. /* Create and send message using qSender */
    48. protected void sendMessage() throws JMSException {
    49. // Create message
    50. TextMessage message = qSession.createTextMessage();
    51. // Set payload
    52. message.setText(username + " Hello");
    53. // Send Message
    54. qSender.send(message);
    55. }
    57. /* Close the JMS connection */
    58. public void close() throws JMSException {
    59. qConnect.close();
    60. }
    62. /* Run the Producer */
    63. public static void main(String args[]) {
    64. String broker, username, password;
    65. if (args.length == 3) {
    66. broker = args[0];
    67. username = args[1];
    68. password = args[2];
    69. } else {
    70. System.out.println("Bitte Parameter angeben (broker username password)");
    71. return;
    72. }
    73. // Create Producer
    74. try {
    75. System.out.println("Hier bin ich schonma");
    76. Producer producer = new Producer(broker, username, password);
    77. System.out.println("hier auch");
    78. // Send the message
    79. producer.sendMessage();
    80. System.out.println("so, jetzt Nachricht gesendet");
    81. // Close connection
    82. producer.close();
    83. } catch (Exception e) {
    84. System.out.println("Fehler: "+e);
    85. }
    86. }
    87. }
    Alles anzeigen


    Danke im Voraus!

  • Um das ganze einmal aufzulösen, falls noch jemand auf dieses Problem stößt.

    Schrittfolge:
    1. OpenMQ
    1.1. Broker anlegen
    1.2. ObjectStroe anlgen
    1.3. ConnectionFactory anlegen
    1.4 Target anlegen
    2. mit Java auf genau diese Objekte zugreifen

    Ein Beispiel Quelltext:

    Quellcode

    1. import javax.jms.*;
    2. import javax.naming.*;
    3. import java.util.Properties;
    5. public class Producer {
    7. private QueueConnectionFactory qFactory = null;
    8. private QueueConnection qConnect = null;
    9. private QueueSession qSession = null;
    10. private Queue sQueue = null;
    11. private QueueSender qSender = null;
    13. private String broker = null;
    14. private String username = null;
    15. private String password = null;
    17. /* Run the Producer */
    18. public static void main(String args[]) {
    19. String broker, username, password;
    20. if (args.length == 3) {
    21. broker = args[0];
    22. username = args[1];
    23. password = args[2];
    24. } else {
    25. broker = "MyQueueConnectionFactory";
    26. username = "admin";
    27. password = "admin";
    29. System.out.println("Nächstes Mal bitte Parameter angeben (broker username password)");
    30. System.out.println("Broker: " + broker);
    31. System.out.println("Username: " + username);
    32. System.out.println("Password: " + password);
    34. }
    35. // Create Producer
    36. try {
    37. System.out.println("Hier bin ich schonma");
    38. Producer producer = new Producer(broker, username, password);
    39. System.out.println("hier auch");
    40. // Send the message
    41. producer.sendMessage();
    42. System.out.println("so, jetzt Nachricht gesendet");
    43. // Close connection
    44. producer.close();
    45. } catch (Exception e) {
    46. System.out.println("Fehler: "+e);
    47. }
    48. }
    51. /* Constructor. Establish the Producer */
    52. public Producer(String broker, String username, String password) throws Exception {
    54. Properties env = new Properties();
    56. // JNDI-Properties
    57. env.put(Context.INITIAL_CONTEXT_FACTORY, "com.sun.jndi.fscontext.RefFSContextFactory");
    58. env.put(Context.PROVIDER_URL, "file:///C:/Temp");
    60. // Netzwerkverbindung zum Namensserver
    61. InitialContext jndi = new InitialContext(env);
    62. //InitialContext jndi = new InitialContext();
    64. this.username = username;
    65. this.password = password;
    67. // Look up a JMS QueueConnectionFactory
    68. qFactory = (QueueConnectionFactory) jndi.lookup(broker);
    70. // Create a JMS QueueConnection object
    71. qConnect = qFactory.createQueueConnection(username, password);
    73. // Create one JMS QueueSession object
    74. qSession = qConnect.createQueueSession(false,Session.AUTO_ACKNOWLEDGE);
    76. // Look up for a JMS Queue hello
    77. sQueue = (Queue) jndi.lookup("MyQueue");
    79. // Create a sender
    80. qSender = qSession.createSender(sQueue);
    82. // Start the Connection
    83. qConnect.start();
    84. }
    86. /* Create and send message using qSender */
    87. protected void sendMessage() throws JMSException {
    88. // Create message
    89. TextMessage message = qSession.createTextMessage();
    90. // Set payload
    91. message.setText(username + " Hello");
    92. // Send Message
    93. qSender.send(message);
    94. }
    96. /* Close the JMS connection */
    97. public void close() throws JMSException {
    98. qConnect.close();
    99. }
    100. }
    Alles anzeigen


    Mehr Infos dazu direkt bei Java MQ: docs.sun.com/app/docs/coll/1307.6 (Achtung! In der PDF-Version des Guides gibt es detailliertere Informationen als in der HTML-Version)