Divertitevi a creare il vostro avatar.
private void inviaMessaggio(String messaggio) {
//Per prima cosa dichiariamo Connection,Session e MessageProducer di javax.jms.
Connection conn = null;
Session session = null;
MessageProducer mp = null;
try{
//Recuperiamo l’initialContext
InitialContext contesto = new InitialContext();
//Facciamo la lookup della ConnectionFactory tramite jndi
ConnectionFactory cf = (ConnectionFactory) contesto.lookup("JMS/NOSTRACF ");
// Facciamo la lookup della Destinazione tramite jndi della coda
Destination destinazione = (Destination) contesto.lookup("JMS/ NOSTRACODA ");
//Creiamo una connessione dalla Connection Factory
conn = cf.createConnection();
//Creiamo la sessione dalla Connessione
session = conn.createSession(false,Session.AUTO_ACKNOWLEDGE);
//Creo il producer passandogli come parametro la nostra destinazione
mp=session.createProducer(destinazione);
//Creo Messaggio
TextMessage message = session.createTextMessage();
//Inserisco il testo del messaggio
message.setText(messaggio);
//Imposto la destinazione del messaggio
message.setJMSDestination(destinazione);
//Imposto la modalità in fase di consegna (NON_PERSISTENT significa che il messaggio verrà letto solo da un singolo consumatore e poi sarà eliminato dalla coda)
mp.setDeliveryMode(DeliveryMode.NON_PERSISTENT);
//Invio Messaggio
mp.send(message);
System.out.println("Messaggio Inviato!!!!");
}catch (Exception e) {
System.out.println("Messaggio Exception!!!!"+e.getMessage());
}finally{
if(conn!=null){try {
session.close();
mp.close();
conn.close();
}catch (Exception e1) {
e1.printStackTrace();
}
}
}
}
private String leggiCoda(ActionMapping mapping, ActionForm form, HttpServletRequest request, HttpServletResponse response) {
//Per prima cosa dichiariamo Connection,Session e MessageConsumer di javax.jms
Connection conn = null;
Session session = null;
MessageConsumer mc = null;
try{
//Recuperiamo l’initialContext
InitialContext contesto = new InitialContext();
//Facciamo la lookup della ConnectionFactory tramite jndi
ConnectionFactory cf = (ConnectionFactory) contesto.lookup("JMS/NOSTRACF ");
// Facciamo la lookup della Destinazione tramite jndi della coda
Destination destinazione = (Destination) contesto.lookup("JMS/ NOSTRACODA ");
//Creiamo una connessione dalla Connection Factory
conn = cf.createConnection();
//Creiamo la sessione dalla Connessione
session = conn.createSession(false,Session.AUTO_ACKNOWLEDGE);
//Creo il consumer passandogli come parametro la nostra destinazione
mc=session.createConsumer(destinazione);
//Apriamo la connessione
conn.start();
//Creiamo un ciclo while per rimanere in ascolto di messaggi presenti nella coda
TextMessage message = null;
while (true) {
Message m = mc.receive(1);
//Se c’è un messaggio restituiamo il testo.
if (m != null) {
message = (TextMessage) m;
System.out.println("Messaggio Ricevuto!!!!");
return message.getText();
}
}
}catch (Exception e) {
System.out.println("Messaggio Exception!!!!"+e.getMessage());
}finally{
if(conn!=null){try {
session.close();
mc.close();
conn.close();
}catch (Exception e1) {
e1.printStackTrace();
}
}
}
return null;
}
