Why am I getting messages in the skipped queue
<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>