View Javadoc

1   /**
2    * The contents of this file are subject to the Mozilla Public License Version 1.1
3    * (the "License"); you may not use this file except in compliance with the License.
4    * You may obtain a copy of the License at http://www.mozilla.org/MPL/
5    * Software distributed under the License is distributed on an "AS IS" basis,
6    * WITHOUT WARRANTY OF ANY KIND, either express or implied. See the License for the
7    * specific language governing rights and limitations under the License.
8    *
9    * The Original Code is "SendAndReceiveAMessage.java".  Description:
10   * "Example Code"
11   *
12   * The Initial Developer of the Original Code is University Health Network. Copyright (C)
13   * 2001.  All Rights Reserved.
14   *
15   * Contributor(s): James Agnew
16   *
17   * Alternatively, the contents of this file may be used under the terms of the
18   * GNU General Public License (the  �GPL�), in which case the provisions of the GPL are
19   * applicable instead of those above.  If you wish to allow use of your version of this
20   * file only under the terms of the GPL and not to allow others to use your version
21   * of this file under the MPL, indicate your decision by deleting  the provisions above
22   * and replace  them with the notice and other provisions required by the GPL License.
23   * If you do not delete the provisions above, a recipient may use your version of
24   * this file under either the MPL or the GPL.
25   *
26   */
27  package ca.uhn.hl7v2.examples;
28  
29  import java.util.concurrent.ArrayBlockingQueue;
30  import java.util.concurrent.ThreadPoolExecutor;
31  import java.util.concurrent.TimeUnit;
32  
33  import ca.uhn.hl7v2.DefaultHapiContext;
34  import ca.uhn.hl7v2.HapiContext;
35  import ca.uhn.hl7v2.app.HL7Service;
36  import ca.uhn.hl7v2.app.SimpleServer;
37  import ca.uhn.hl7v2.llp.ExtendedMinLowerLayerProtocol;
38  import ca.uhn.hl7v2.parser.PipeParser;
39  
40  /**
41   * Example code
42   * 
43   * @author James Agnew
44   * @author Christian Ohr
45   */
46  public class CustomThreading {
47  
48  
49  	@SuppressWarnings("unused")
50     public static void main(String[] args) throws Exception {
51  
52          // Instantiate a custom executor service to be used
53          ThreadPoolExecutor executor = new ThreadPoolExecutor(
54                  10, 100,
55                  30, TimeUnit.SECONDS,
56                  new ArrayBlockingQueue<Runnable>(100));
57          executor.setRejectedExecutionHandler(new ThreadPoolExecutor.CallerRunsPolicy());
58  
59  		/*
60  		 * Custom Threading with HapiContext (HAPI 2.1)
61  		 */
62  		int port = 1011; // The port to listen on
63  		HapiContext context = new DefaultHapiContext();
64          context.setExecutorService(executor);
65  		HL7Service server = context.newServer(port, false);
66          // server.startAndWait();
67  
68  		/*
69  		 * Custom Threading without HapiContext (HAPI 2.0)
70  		 */
71          server = new SimpleServer(port, new ExtendedMinLowerLayerProtocol(), new PipeParser(), false, executor);
72          // server.startAndWait();
73  
74          executor.shutdown();
75  
76  	}
77  
78  }