1 package net.walend.somnifugi.juc; 2 3 import java.util.Hashtable ; 4 5 import javax.naming.Context ; 6 import javax.naming.NamingException ; 7 8 import javax.jms.Message ; 9 10 import net.walend.somnifugi.SomniProperties; 11 import net.walend.somnifugi.SomniNamingException; 12 import net.walend.somnifugi.SomniDestination; 13 14 import net.walend.somnifugi.channel.ChannelFactory; 15 import net.walend.somnifugi.channel.Channel; 16 import net.walend.somnifugi.channel.Puttable; 17 import net.walend.somnifugi.channel.Takable; 18 19 28 29 public class MessageSelectingPriorityChannelFactory 30 implements ChannelFactory<Message > 31 { 32 public MessageSelectingPriorityChannelFactory() 33 { 34 JUCLogger.IT.finer("Creating new MessageSelectingPriorityChannelFactory."); 35 } 36 37 public Channel<Message > createChannel(String destinationName,Context context) 38 throws SomniNamingException 39 { 40 JUCLogger.IT.finest("Creating MessageSelectingPriorityChannel for "+destinationName); 41 42 return new MessageSelectingPriorityChannel(); 43 } 44 } 45 46 66 | Popular Tags |