code: @Override
      public void createControlAdapter()
      {
          if (TraceComponent.isAnyTracingEnabled() && tc.isEntryEnabled())
              SibTr.entry(tc, "createControlAdapter");
  
          DestinationHandler dh = null;
          try
          {
              ReferenceStream rs = getReferenceStream();
              if (rs instanceof MessageReferenceStream)
              {
                  ItemStream is = rs.getItemStream();
                  if (is instanceof PubSubMessageItemStream)
                  {
                      dh = ((PubSubMessageItemStream) is).getDestinationHandler();
                      controlAdapter = new QueuedMessage(this, dh, rs);
                  }
              }
          } catch (Exception e)
          {
              // FFDC
              FFDCFilter.processException(
                                          e,
                                          "com.ibm.ws.sib.processor.impl.store.items.MessageItemReference.createControlAdapter",
                                          "1:1266:1.147",
                                          this);
  
              SibTr.exception(tc, e);
          }
  
          if (TraceComponent.isAnyTracingEnabled() && tc.isEntryEnabled())
              SibTr.exit(tc, "createControlAdapter");
      }
docs: /*
  (non-Javadoc)
  
  @see com.ibm.ws.sib.processor.impl.interfaces.ControllableResource#createControlAdapter()