001 /*
002 * Copyright 2005 Stephen J. McConnell.
003 *
004 * Licensed under the Apache License, Version 2.0 (the "License");
005 * you may not use this file except in compliance with the License.
006 * You may obtain a copy of the License at
007 *
008 * http://www.apache.org/licenses/LICENSE-2.0
009 *
010 * Unless required by applicable law or agreed to in writing, software
011 * distributed under the License is distributed on an "AS IS" BASIS,
012 * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or
013 * implied.
014 *
015 * See the License for the specific language governing permissions and
016 * limitations under the License.
017 */
018
019 package net.dpml.test.app;
020
021 import java.util.List;
022 import java.util.LinkedList;
023 import java.util.Iterator;
024
025 /**
026 * A server.
027 *
028 * @author <a href="http://www.dpml.net">Digital Product Meta Library</a>
029 * @version 1.2.0
030 */
031 public class DefaultServer implements Server
032 {
033 //------------------------------------------------------------------
034 // concerns
035 //------------------------------------------------------------------
036
037 /**
038 * The construction criteria.
039 */
040 public interface Context
041 {
042 /**
043 * Return the port.
044 * @param defaultPort the default port
045 * @return the port.
046 */
047 int getPort( int defaultPort );
048 }
049
050 //------------------------------------------------------------------
051 // state
052 //------------------------------------------------------------------
053
054 private final int m_port;
055
056 private List m_listeners = new LinkedList();
057
058 //------------------------------------------------------------------
059 // constructor
060 //------------------------------------------------------------------
061
062 /**
063 * Creation of a new singleton component instance.
064 * @param context a context implementation fullfilling the context criteria
065 */
066 public DefaultServer( final Context context )
067 {
068 m_port = context.getPort( 1234 );
069
070 // setup port listener
071 }
072
073 //------------------------------------------------------------------
074 // Server
075 //------------------------------------------------------------------
076
077 /**
078 * Add a listener.
079 * @param listener the listener
080 */
081 public void addListener( Listener listener )
082 {
083 synchronized( m_listeners )
084 {
085 if( m_listeners.contains( listener ) )
086 {
087 throw new IllegalStateException( "Listener already registered." );
088 }
089 m_listeners.add( listener );
090 }
091 }
092
093 //------------------------------------------------------------------
094 // testcase hook
095 //------------------------------------------------------------------
096
097 /**
098 * Rather than fully implementing this component we are cheating by
099 * providing this hook so that the testcase can fire the notification.
100 * @param message the message supplied by the testcase to be forwarded
101 * by the implementation to registereed listeners
102 */
103 public void triggerNotify( String message )
104 {
105 synchronized( m_listeners )
106 {
107 Iterator iterator = m_listeners.iterator();
108 while( iterator.hasNext() )
109 {
110 Listener listener = (Listener) iterator.next();
111 listener.notify( message );
112 }
113 }
114 }
115 }