Struct DirectStimulus 

pub struct DirectStimulus { /* private fields */ }

The route stimulus for a booted scenario (ADR-0069 section 5): a scenario send addressed to a CONTEXT component endpoint (direct:) must reach the booted system under test, not a partner. This adapter delivers the message through the context’s own producer path — a fresh direct: endpoint and producer per send, one oneshot per exchange, retrying the consumer-startup race — the same mechanism camel-test and camel run use to stimulate routes.

Key the router map by the exact endpoint URI the scenario’s send addresses (direct:start). receive is not a context role: it fails at the transport, apparatus class.

Implementations

impl DirectStimulus

pub fn new(ctx: Arc<AsyncMutex<CamelContext>>) -> Self

Wraps the booted context the scenario sends into.

Trait Implementations

impl PartnerAdapter for DirectStimulus

fn send<'a>( &'a self, lane_key: &'a str, _target_uri: &'a str, msg: OutgoingMessage, ) -> BoxFuture<'a, Result<(), TransportError>>

Send a message to the target URI, parking any roundtrip under the lane key. Adapters without a client role keep the default (a transport failure naming the gap); the http partner is one such adapter — the router’s own client lane performs every http client-role send.

fn receive<'a>( &'a self, _lane_key: &'a str, source_uri: &'a str, _deadline: Duration, ) -> BoxFuture<'a, Result<IncomingMessage, ReceiveError>>

Receive a message from the source URI before the deadline passes. Implementations must respect the deadline; they never hang past it.

fn bound_authority(&self) -> Option<String>

The host:port authority this adapter’s listener bound, when it owns one (the http partner); None otherwise. The router uses it to resolve declared and dynamic endpoint references to real wire addresses.