class JmsSyncConsumer extends BaseJmsPollingConsumerImpl {

  @Override
  protected MessageConsumer createConsumer() throws JMSException {
    String rfc6167 = endpoint();
    String filterExp = messageSelector();

    VendorImplementation vendor = retrieveConnection(JmsConnection.class).configuredVendorImplementation();
    return new JmsMessageConsumerFactory(vendor, currentSession(), rfc6167, deferConsumerCreationToVendor(), filterExp, this)
        .create();
  }

  public  JmsSyncConsumer();

}