JMS - Problem mit TemporaryQueue

Status
Nicht offen für weitere Antworten.

megachucky

Bekanntes Mitglied
Hallo.

Ich habe einen Client und einen Server. Der Server empfängt 5 Nachrichten und soll jeweils an die Temporary Queue eine Antwort senden.

Ich benutze den Glassfish Application Server und starte beide Klassen mit appclient.

Der Client sendet die erste Nachricht und bekommt auch eine Antwort vom Server, die zweite Nachricht empängt der Sever zwar noch, gibt aber keine Antwort mehr und hängt.

Ich vermute, es passt etwas mit JMSCorrelationID oder JMSMessageID nicht und der Server schickt zwar eine zweite Nachricht, diese wird aber anscheinend auf Client Seite nicht korrekt empfangen / ist nicht zuordbar ?!?

Kann mir jemand weiterhelfen?

Danke.


Hier der Code:

Code:
public ServerSetup() {
		
		logger = Logger.getLogger("ClientSetup");
		logger.setLevel(Level.INFO);
		
		try {
			context = new InitialContext();
			connectionFactory = (ConnectionFactory) context.lookup("jms/ConnFact");
			connection = connectionFactory.createConnection();
			
			queue = (Queue) context.lookup("jms/Queue");
//			topic = (Topic) context.lookup("jms/Topic");
			
			session = connection.createSession(false, Session.AUTO_ACKNOWLEDGE);
			
			MessageConsumer consumer = session.createConsumer(queue);
			
			connection.start();
			logger.info("start consuming text messages");
			
			while (true) {
		
				TextMessage textMessage = (TextMessage) consumer.receive();
				
				if (textMessage.getText().equals("dummy")) {
					break;
				}
				
				logger.info(textMessage.getJMSMessageID() + ": " + textMessage.getText());
				
				Queue replyQueue = (Queue) textMessage.getJMSReplyTo();
				
				MessageProducer replyProducer = session.createProducer(replyQueue);
				TextMessage replyMessage = session.createTextMessage();
				replyMessage.setText("ANSWER - Message " + textMessage.getJMSMessageID() + " arrived");
				replyMessage.setJMSCorrelationID(textMessage.getJMSMessageID());

				replyProducer.send(replyMessage);
			
				
			}
			
			logger.info("text messages received");
			
			
			session.close();
			connection.close();
		}
			
		catch (NamingException e) {
			e.printStackTrace();
		}
		
		 catch (JMSException e) {
			e.printStackTrace();
		}
		
	}
	
}



Code:
	public ClientSetup() {
		
		System.out.println("test");
		
		logger = Logger.getLogger("ServerSetup");
		logger.setLevel(Level.INFO);
		
		try {
			context = new InitialContext();
			connectionFactory = (ConnectionFactory) context.lookup("jms/ConnFact");
			connection = connectionFactory.createConnection();
			
			queue = (Queue) context.lookup("jms/Queue");
//			topic = (Topic) context.lookup("jms/Topic");
			
			session = connection.createSession(false, Session.AUTO_ACKNOWLEDGE);
			
			MessageProducer producer = session.createProducer(queue);
			TemporaryQueue temporaryQueue = session.createTemporaryQueue();
			
			connection.start();
			
			for (int i=0; i<5; i++) {
				
				TextMessage textMessage = session.createTextMessage();
				textMessage.setText("jms queue test " + i);
				textMessage.setJMSReplyTo(temporaryQueue);
				MessageConsumer consumer = session.createConsumer(temporaryQueue);
				
				
				producer.send(textMessage);
				logger.info("message " + textMessage.getJMSMessageID() + " sent: \n" + textMessage.getText() );
				
				TextMessage confirmation = (TextMessage) consumer.receive();
				logger.info("Confirmation: " + confirmation.getText());
				
			}
			// leere Message zum Abschluss
			TextMessage dummy = session.createTextMessage();
			dummy.setText("dummy");
			producer.send(dummy);
			
			logger.info("text messages sent");
			
	
			session.close();
			connection.close();
		}
			
		catch (NamingException e) {
			e.printStackTrace();
		}
		
		 catch (JMSException e) {
			e.printStackTrace();
		}
		
	}

}
 

megachucky

Bekanntes Mitglied
Nebenbei noch eine zweite Frage:

Ich kann zwar die ConnectionFactory und Queue über den Context-Lookup holen, aber eigentlich wollte ich es so machen:

@Resource(mappedName="jms/ConnFact")
private ConnectionFactory connectionFactory;

Dies funktioniert aber leider nicht und bringt immer eine NullPointer. Kanns sich das jemand erklären ?!?
Andere Annotation wie zb für EJBs oder Entities funktionieren einwandfrei.
 
Status
Nicht offen für weitere Antworten.
Ähnliche Java Themen
  Titel Forum Antworten Datum
D Problem mit Update von ApacheHttpClient von 5.2 auf 5.3 Allgemeines EE 10
D Problem mit redundanten Servern Allgemeines EE 7
Azemaria JSF: Problem bei der einfachsten Applikation Allgemeines EE 2
P JPA Internal Problem Nullpointer Allgemeines EE 10
S MessageDrivenBean Problem beim Zugriff auf Stateful EJB Allgemeines EE 2
M Glassfish Deployment-Problem unter Eclipse Allgemeines EE 0
B Problem beim Lesen des Codes... Allgemeines EE 2
R JPA Problem beim Speichern eines Users Allgemeines EE 2
S WebSocket Problem Allgemeines EE 0
F Eclipse/Java EE Debug-Problem Allgemeines EE 1
G Problem: Servlet in JSP einbinden mit <jsp:include> Allgemeines EE 3
Raidri [SEAM] rich:dataTable sortBy Problem Allgemeines EE 6
T Problem mit den Beispielen von Apache Allgemeines EE 5
W JSF Validator Problem HTTP Status 500 Allgemeines EE 2
E JBoss 7.1 Datasource Problem Allgemeines EE 2
M JSP Problem -unbestimmte Anzahl von Werten Transportieren Allgemeines EE 9
S Problem mit EJB Verständnis Allgemeines EE 4
B Problem beim einbinden einer CSS in eine JSP Allgemeines EE 8
F JSP Problem mit Datenbankanbindung über Glassfishserver Allgemeines EE 4
S java Entities Problem Allgemeines EE 19
S Embedded JBoss Problem beim Deployment Allgemeines EE 4
E Session Problem Allgemeines EE 9
F problem mit nullpointer bei DB zugriff Allgemeines EE 2
A Erste Schritte... Problem mit Hibernate Allgemeines EE 15
ruutaiokwu jboss problem - work-verzeichnis muss manuell gelöscht werden??? Allgemeines EE 5
Stillmatic sendRedirect Problem! Allgemeines EE 3
M Problem mit Lookup auf EJB3 mit Glassfish Allgemeines EE 11
0 Problem mit librarys javax.servlet.http.HttpServletRequest cannot be resolved Allgemeines EE 1
X JBoss InitialContext problem Allgemeines EE 5
LordZed Problem mit dem einbinden von Bibliotheken, die sich gegenseitig verwenden Allgemeines EE 5
H GWT Problem beim Ausführen Allgemeines EE 8
Q Problem mit JMS und Weblogic 10 Allgemeines EE 5
E Performance-Problem beim ersten Request Allgemeines EE 4
G Multi User Problem Allgemeines EE 8
G Datasource Problem Allgemeines EE 1
J OOP Java Array Problem Allgemeines EE 2
T Problem mit Java Transaction API Allgemeines EE 2
D Problem mit EJB: Bean soll Objekt eigener Klasse zurückgeben Allgemeines EE 2
N JavaMail Problem Allgemeines EE 4
N JBoss Problem mit Bibliothek in unterschiedlichen Versionen Allgemeines EE 2
A Tomcat -- JSP: komisches Problem Allgemeines EE 11
W Speicher-Problem bei WebApp unter Tomcat, Struts, Hibernate Allgemeines EE 3
B Problem mit ActionListener Allgemeines EE 13
G Simples JSF-Projekt in Eclipse - Problem Allgemeines EE 9
O eclipse - tomcat: Problem bei einfachem Webservice Allgemeines EE 16
J Problem mit EJB Aufruf und DualCore Rechner Allgemeines EE 4
J ejb3.0 datenbank problem Allgemeines EE 2
J Problem mit Zurück-Button Allgemeines EE 2
T Tomcat: JNDI + JDBC Problem Allgemeines EE 3
J problem mit jsp/js Allgemeines EE 2
B Help - EJB2 - Problem mit Hybernate und "LIMIT" Allgemeines EE 6
B JSTL Problem Allgemeines EE 8
byte Tomcat Deployment Problem (HTTP Status 503) Allgemeines EE 8
S Problem mit t:selectOneRadio und ValueChangeListener Allgemeines EE 2
S Problem mit Struts und tiles Allgemeines EE 4
B Problem mit JBoss-4.2.1.GA Allgemeines EE 8
N Tiles - JSF Problem Allgemeines EE 3
M JSF & EJB "Bean not bound" Problem Allgemeines EE 4
V MYSQL JDBC;java.lang.ClassNotFoundException; Problem Eclipse Allgemeines EE 3
G Problem mit MimeType/ContentType Allgemeines EE 4
E Java Mail problem Allgemeines EE 5
Y XFire - Maven Build Problem Allgemeines EE 2
D JSP Problem mit equals? Allgemeines EE 2
A Eclipse Start-Problem Allgemeines EE 5
S JSF - Custom converter Problem Allgemeines EE 3
Y JSF Uhrzeitausgabe Problem Allgemeines EE 4
M servlet --> jsp - problem beim umstrukturieren Allgemeines EE 5
Y JSF - rendered Problem Allgemeines EE 1
D Servlet Problem über Server Allgemeines EE 26
Zed JSF h:inputText h:outputText update Problem Allgemeines EE 2
K mysql treiber problem wenn import java.sql.* bei _servlet_ Allgemeines EE 2
S JDBC Mysql Connection Problem - datasource null Allgemeines EE 3
T Session-Problem Allgemeines EE 2
R Tiles - Layout-Problem wegen Leerzeichen Allgemeines EE 6
G Tomcat / Eclipse oder Web.xml Problem Allgemeines EE 11
S Netbeans 5.5 Visual Web Pack Problem mit INSERT und PK Allgemeines EE 4
D JSF Problem mit Action Allgemeines EE 2
F Klassen und zugriffs Problem "Help wanted"! Allgemeines EE 16
D <input type="file"> Problem Allgemeines EE 6
N Struts - Problem mit <html:link> Action Allgemeines EE 3
A Problem / Fehler beim Einbinden einer Klasse in ein JSP Allgemeines EE 20
G Session Problem Allgemeines EE 5
T Ant Compiler Problem Allgemeines EE 9
T Problem dem Zaehler in mein Java - Code Allgemeines EE 2
A Hibernate-Problem mit MySQL-Cluster Allgemeines EE 6
H Servlet problem Allgemeines EE 10
G Problem mit Benutzerverwaltung Allgemeines EE 3
S Hibernate Mapping Problem Allgemeines EE 3
S Hibernate INSERT Problem Allgemeines EE 11
S Dummes JSP-Problem Allgemeines EE 8
P EJB-Installations-Problem Allgemeines EE 4
S CSS Problem in JSP Allgemeines EE 16
C Problem mit html:optionsCollection Allgemeines EE 4
R HILFE: Problem mit JSF examples Allgemeines EE 10
R Problem mit value-expression Allgemeines EE 7
R Problem mit for-schleife in JSP tag Allgemeines EE 8
B Struts Problem: Array in JSP ausgeben (logic:iterate) Allgemeines EE 12
M Redirct-Problem Allgemeines EE 4
M Geronimo v1.1 - Problem mit EAR deployen Allgemeines EE 5
S Problem mit Servlet Allgemeines EE 11

Ähnliche Java Themen

Neue Themen


Oben