import javax.jms.TextMessage;
import javax.jms.QueueConnectionFactory;
import javax.jms.QueueSender;
import javax.jms.QueueSession;

import net.jxta.peergroup.PeerGroup;
import net.jxta.pipe.OutputPipe;

public class Router
{
    private String peerName = "";
    private PeerGroup peerGroup = null;


    public Router ( String peerName, PeerGroup peerGroup ) {
        this.peerName = peerName;
        this.peerGroup = peerGroup;

    }//Router


    public void sendMessageToMobile( 
                                   String sender, 
                                   OutputPipe outputPipe, 
                                   TextMessage jmsMessage ) {
        try
        {
            System.out.println ("Sender is : "+sender);
            System.out.println ( "\nMessage is : \n" +
                                   jmsMessage.getText() +"\n" 
                               );

            JMSToJXTAMsgConverter jxtaConverter = new JMSToJXTAMsgConverter ( sender, jmsMessage );
            net.jxta.endpoint.Message jxtaMessage = jxtaConverter.getMessage ();
            outputPipe.send ( jxtaMessage );

            System.out.println ("Router>> Message sent for mobile-side JXTA4JMS.");
        }
        catch ( Exception e ) 
        {
            e.printStackTrace ();
        }

    }//sendMessageToMobile()


    public void sendMessageToJMS( QueueConnectionFactory qConnFactory, 
                                  net.jxta.endpoint.Message jxtaMessage )
    {
        try
        {
            System.out.println ("Router>> Sending JXTA message to JMS domain...");
            JXTAToJMSMsgConverter jmsConverter = new JXTAToJMSMsgConverter (
                                                       qConnFactory,
                                                       jxtaMessage
                                                     );

            String jmsRecipient = jmsConverter.getJMSRecipient();
            TextMessage jmsMessage = jmsConverter.getMessage();
            QueueSession queueSession = jmsConverter.getQueueSession();
            
            JMSSearch jmsSearch = new JMSSearch ();

            QueueSender qSender = jmsSearch.getQueueSender ( jmsRecipient,
                                                             queueSession );
            
            qSender.send ( jmsMessage);
            
            System.out.println ( "\nFolliwing msg sent to: " + jmsConverter.getJMSRecipient()+
                                 "\n\nMessage is : \n" +
                                 jmsMessage.getText() + "\n" 
                               );
        }
        catch ( Exception e )
        {
            e.printStackTrace ();
        }
    }//sendMessageToJMS
    
}//end of class Router