protected AbstractResponsePacket process ( AbstractQueryPacket query ) throws JMSException { switch ( query . getType ( ) ) { case PacketType . Q_GET : return processGet ( ( GetQuery ) query ) ; case PacketType . Q_PUT : return processPut ( ( PutQuery ) query ) ; case PacketType . Q_COMMIT : return processCommit ( ( CommitQuery ) query ) ; case PacketType . Q_ACKNOWLEDGE : return processAcknowledge ( ( AcknowledgeQuery ) query ) ; case PacketType . Q_ROLLBACK : return processRollback ( ( RollbackQuery ) query ) ; case PacketType . Q_RECOVER : return processRecover ( ( RecoverQuery ) query ) ; case PacketType . Q_CREATE_SESSION : return processCreateSession ( ( CreateSessionQuery ) query ) ; case PacketType . Q_CLOSE_SESSION : return processCloseSession ( ( CloseSessionQuery ) query ) ; case PacketType . Q_CREATE_CONSUMER : return processCreateConsumer ( ( CreateConsumerQuery ) query ) ; case PacketType . Q_CREATE_DURABLE_SUBSCRIBER : return processCreateDurableSubscriber ( ( CreateDurableSubscriberQuery ) query ) ; case PacketType . Q_CREATE_BROWSER : return processCreateBrowser ( ( CreateBrowserQuery ) query ) ; case PacketType . Q_CREATE_BROWSER_ENUM : return processQueueBrowserGetEnumeration ( ( QueueBrowserGetEnumerationQuery ) query ) ; case PacketType . Q_BROWSER_ENUM_FETCH : return processQueueBrowserFetchElement ( ( QueueBrowserFetchElementQuery ) query ) ; case PacketType . Q_CLOSE_CONSUMER : return processCloseConsumer ( ( CloseConsumerQuery ) query ) ; case PacketType . Q_CLOSE_BROWSER : return processCloseBrowser ( ( CloseBrowserQuery ) query ) ; case PacketType . Q_CLOSE_BROWSER_ENUM : return processCloseBrowserEnumeration ( ( CloseBrowserEnumerationQuery ) query ) ; case PacketType . Q_CREATE_TEMP_QUEUE : return processCreateTemporaryQueue ( ( CreateTemporaryQueueQuery ) query ) ; case PacketType . Q_CREATE_TEMP_TOPIC : return processCreateTemporaryTopic ( ( CreateTemporaryTopicQuery ) query ) ; case PacketType . Q_DELETE_TEMP_QUEUE : return processDeleteTemporaryQueue ( ( DeleteTemporaryQueueQuery ) query ) ; case PacketType . Q_DELETE_TEMP_TOPIC : return processDeleteTemporaryTopic ( ( DeleteTemporaryTopicQuery ) query ) ; case PacketType . Q_OPEN_CONNECTION : return processOpenConnection ( ( OpenConnectionQuery ) query ) ; case PacketType . Q_START_CONNECTION : return processStartConnection ( ) ; case PacketType . Q_STOP_CONNECTION : return processStopConnection ( ) ; case PacketType . Q_SET_CLIENT_ID : return processSetClientID ( ( SetClientIDQuery ) query ) ; case PacketType . Q_UNSUBSCRIBE : return processUnsubscribe ( ( UnsubscribeQuery ) query ) ; case PacketType . Q_PREFETCH : return processPrefetch ( ( PrefetchQuery ) query ) ; case PacketType . Q_PING : return processPing ( ) ; case PacketType . Q_ROLLBACK_MESSAGE : return processRollbackMessage ( ( RollbackMessageQuery ) query ) ; default : throw new javax . jms . IllegalStateException ( "Unkown query type id : " + query . getType ( ) ) ; } }
Process an incoming packet