code: @Override
  	public Destination getDestination(PeerDescriptor peer, DestinationReferenceDescriptor destinationReference,Session session) throws JMSException
  	{
  		String destinationType = destinationReference.getDestinationType();
  		String destinationName = destinationReference.getDestinationName();
  		
  		if (destinationType.equalsIgnoreCase("queue"))
  		{
  			return session.createQueue(destinationName);
  		}
  		else
  		if (destinationType.equalsIgnoreCase("topic"))
  		{
  			return session.createTopic(destinationName);
  		}
  		else
  			throw new IllegalArgumentException("Invalid destination type : "+destinationType);
  	}
docs: /* (non-Javadoc)
  @see net.timewalker.ffmq4.cluster.resolver.DestinationResolver#getDestination(net.timewalker.ffmq4.management.peer.PeerDescriptor, net.timewalker.ffmq4.management.destination.DestinationReferenceDescriptor, javax.jms.Session)