Package lupos.event.communication

Examples of lupos.event.communication.SerializingMessageService

153
154
155
156
157
158
159
160
161
162
163
   * @throws Exception
   */
  public static void main(String[] args) throws Exception {   

    // create communication channel
    SerializingMessageService msgService = ProducerBase.connectToMaster();

   
    LottoProducer wtp = LottoProducer.createLottoProducer(msgService);
    // start producer
    wtp.start();
View Full Code Here
128
129
130
131
132
133
134
135
136
137
138
   * @throws Exception
   */
  public static void main(String[] args) throws Exception {

    // create communication channel
    SerializingMessageService msgService = ProducerBase.connectToMaster();
   
    String location = JOptionPane.showInputDialog("Enter location to get weather:", defaultlocation);
   
    WaterTempProducer wtp = WaterTempProducer.createWaterTempProducer(msgService, location);
    // start producer
View Full Code Here
157
158
159
160
161
162
163
164
165
166
167
   * @throws Exception
   */
  public static void main(String[] args) throws Exception {
   
    // create communication channel
    SerializingMessageService msgService = ProducerBase.connectToMaster();
   
    String location = JOptionPane.showInputDialog("Enter location to get weather:", defaultLocation);
    WindFinderProducer wp = WindFinderProducer.createWindFinderProducer(msgService, location);
    // start producer
    wp.start();   
View Full Code Here
327
328
329
330
331
332
333
334
335
336
   *
   * @throws Exception
   */
  public static void main(String[] args) throws Exception {
    // create communication channel
    SerializingMessageService msgService = ProducerBase.connectToMaster();

    // start producer
    new DBDelayProducer(msgService, 30000).start();
  }
View Full Code Here
337
338
339
340
341
342
343
344
345
346
347
   * @param args command line parameter
   * @throws Exception
   */
  public static void main(String[] args) throws Exception {
    // create communication channel
    SerializingMessageService msgService = ProducerBase.connectToMaster();
   
    // create new WeatherProducer
    WeatherProducer wp = new WeatherProducer(msgService);
   
    // create windows to choose the country and city you want to search
View Full Code Here
161
162
163
164
165
166
167
168
169
170
171
   * @param args
   * @throws Exception
   */
  public static void main(String[] args) throws Exception {
    //Create communication channel
    SerializingMessageService msgService = ProducerBase.connectToMaster();
   
    EventsProducer tsp = new EventsProducer(msgService);
   
    //Show dialog message boxes
    tsp.SEARCH_CITY = JOptionPane.showInputDialog("Enter keyword for city or country:", tsp.SEARCH_CITY);
View Full Code Here
169
170
171
172
173
174
175
176
177
178
179
180
181
182
183
   * and afterwards send a connection request message to it
   * @return msgService the message service of the connection
   */
  protected static SerializingMessageService connectToMaster(){
    // create communication channel
    SerializingMessageService msgService = null;
    try {
      msgService = new SerializingMessageService(TcpMessageTransport.class);
      msgService.connect(new TcpConnectInfo(JOptionPane.showInputDialog("Enter the host IP adress of the MasterBroker:", "localhost"), Integer.parseInt(JOptionPane.showInputDialog("Enter the host port of the MasterBroker:", "4444"))));
      msgService.sendMessage(new ConnectionRequest(ConnectionRequest.REQUESTTYPE_PRODUCER));
    } catch (Exception e) {
      e.printStackTrace();
    }
    return msgService;
  }
View Full Code Here
105
106
107
108
109
110
111
112
113
114
115
  }

 
  public static void main(String[] args) throws Exception {
    // create communication channel
    SerializingMessageService msgService = ProducerBase.connectToMaster();
   
    TwitterSearchProducer tsp = new TwitterSearchProducer(msgService);
   
    tsp.SEARCH_QUERY = JOptionPane.showInputDialog("Enter keyword to be searched for on twitter:", tsp.SEARCH_QUERY);
   
View Full Code Here
57
58
59
60
61
62
63
64
65
66
67
      SerializingMessageService msgService) {
    super(msgService, INTERVAL);
  }

  public static void main(String[] args) throws Exception {
    SerializingMessageService msgService = ProducerBase.connectToMaster();
   
    RSSSemanticInterpretationProducer rt = new RSSSemanticInterpretationProducer(msgService);
    rt.start();
    rt.produce();
View Full Code Here
63
64
65
66
67
68
69
70
71
72
73
  private void start() throws Exception{
    new Thread(this).start();
    System.out.println("Master Broker started. Waiting for incoming services...");
    while (true){
      // create communication endpoint and wait for an incoming connection
      SerializingMessageService msgService = new SerializingMessageService(TcpMessageTransport.class);
      msgService.addHandler2(this);
      msgService.waitForConnection();
     
    }
  }
View Full Code Here
TOP

Related Classes of lupos.event.communication.SerializingMessageService

  • lupos.event.broker.distributed.MasterBroker
  • lupos.event.producer.AlarmProducer
  • lupos.event.producer.BTDevicesProducer
  • lupos.event.producer.ButtonClickedProducer
  • lupos.event.producer.CountProducer
  • lupos.event.producer.DBDelayProducer
  • lupos.event.producer.ebay.EbayProducer
  • lupos.event.producer.EventsProducer
  • lupos.event.producer.MensaProducer
  • lupos.event.producer.MoonProducer
    • Copyright © 2018 www.massapicom. All rights reserved.
    All source code are property of their respective owners. Java is a trademark of Sun Microsystems, Inc and owned by ORACLE Inc. Contact coftware#gmail.com.