sdrtrunk/src/decode/p25/P25MessageProcessor.java

package decode.p25;

import java.util.HashMap;

import message.Message;

import org.slf4j.Logger;
import org.slf4j.LoggerFactory;

import sample.Broadcaster;
import sample.Listener;
import alias.AliasList;
import decode.p25.message.IdentifierReceiver;
import decode.p25.message.tsbk.osp.control.IdentifierUpdate;

public class P25MessageProcessor implements Listener<Message>
{
	private final static Logger mLog = 
			LoggerFactory.getLogger( P25MessageProcessor.class );

	private Broadcaster<Message> mBroadcaster = new Broadcaster<Message>();

	/* Map of up to 16 band identifiers per RFSS.  These identifier update 
	 * messages are inserted into any message that conveys channel information
	 * so that the uplink/downlink frequencies can be calculated */
	private HashMap<Integer,IdentifierUpdate> mIdentifierMap = 
			new HashMap<Integer,IdentifierUpdate>();
	
	private AliasList mAliasList;
	
	public P25MessageProcessor( AliasList aliasList )
	{
		mAliasList = aliasList;
	}
	
	@Override
    public void receive( Message message )
    {
		if( message.isValid() )
		{
			/* Insert band identifier update messages into channel-type messages */
			if( message instanceof IdentifierReceiver )
			{
				IdentifierReceiver receiver = (IdentifierReceiver)message;
				
				int[] identifiers = receiver.getIdentifiers();
				
				for( int identifier: identifiers )
				{
					receiver.setIdentifierMessage( identifier, 
									mIdentifierMap.get( identifier ) );
				}
			}

			/* Store band identifiers so that they can be injected into channel
			 * type messages */
			if( message instanceof IdentifierUpdate )
			{
				IdentifierUpdate identifierUpdate = (IdentifierUpdate)message;
				
				mIdentifierMap.put( identifierUpdate.getIdentifier(), identifierUpdate );
			}
			
			mBroadcaster.broadcast( message );
		}
    }
	
	public void dispose()
	{
		mIdentifierMap.clear();
		mBroadcaster.dispose();
	}
	
    public void addMessageListener( Listener<Message> listener )
    {
    	mBroadcaster.addListener( listener );
    }

    public void removeMessageListener( Listener<Message> listener )
    {
    	mBroadcaster.removeListener( listener );
    }
}