title: Why am I getting messages in the skipped queue
body: <p>I have a saga setup in a fork/join configuration. </p>
  
  <h3>Events defined on the saga</h3>
  
  <ul>
  <li><code>FileMetadataMsg</code></li>
  <li><code>FileReadyMsg</code></li>
  <li><code>SomeOtherMsg</code></li>
  </ul>
  
  <h3>Process starts off when a file comes in on a separate listener.</h3>
  
  <ul>
  <li>Publishes <code>SagaStart(correlationId)</code></li>
  <li>Publishes <code>FileSavedToMsg(correlationId, fileLoc)</code></li>
  <li>Publishes <code>FileMetadataMsg(correlationId, metadata)</code></li>
  <li>Publishes <code>FileReadyMsg(correlationId, fileLoc)</code></li>
  </ul>
  
  <h3>Downstream endpoint of  does some work on the file</h3>
  
  <p><code>Consumer&lt;FileSavedToMsg&gt;</code></p>
  
  <ul>
  <li>Publishes <code>SomeOtherMsg(GotTheFileMsg.correlationId, data)</code></li>
  </ul>
  
  <p>I am getting a FileSavedToMsg in the saga_skipped queue. I can only assume it's due to having a correlationId on the FileSavedToMsg because the saga itself is not using FileSavedToMsg in its state machine and does not have an <code>Event&lt;FileSavedToMsg&gt;</code>.</p>
  
  <p>If this is the reason why...should I be passing the correlationId along in a field other than the CorrelationId, so the saga doesn't see it? I need it somewhere so I can tag SomeOtherMsg with it.</p>
  
  <p>Here is how the saga endpoint is defined</p>
  
  <pre><code>return Bus.Factory.CreateUsingRabbitMq(cfg =&gt;
  {
      var host = cfg.Host(new Uri("rabbitmq://localhost/"), h =&gt;
              {
                  h.Username("guest");
                  h.Password("guest");
              });              
  
              cfg.ReceiveEndpoint(host, "study_saga", epCfg =&gt;
              {
                  epCfg.StateMachineSaga(machine, repository);
              });
  });
  </code></pre>
  
  <p>Here is how the worker endpoint is defined</p>
  
  <pre><code>return Bus.Factory.CreateUsingRabbitMq(x =&gt;
  {
      var host = x.Host(new Uri("rabbitmq://localhost/"), h =&gt;
          {
              h.Username("guest");
              h.Password("guest");
          });
  
          x.ReceiveEndpoint(host, "study_3d_volume_worker", c =&gt;
          {
              c.PrefetchCount = 1;
              c.Instance(_studyCreatedMsgConsumer);
          });
   });
  </code></pre>
  
  <p>These are running on the same machine, but in seperate Console/Topshelf applications.</p>