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<Option<Exchange>, TransportError>>

Send a message to the target URI, parking any roundtrip under the lane key, and return the synchronous reply when the adapter produces one: the context-stimulus direct: send returns the routed exchange (Ok(Some(..))) so an expectReply assertion can read it (rc-qvz6); partner and fake adapters answer Ok(None). 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.

fn set_secret_query_keys(&self, keys: &[String])

Stores the query keys classified secret (ADR-0051 positive secret rule) for the adapter’s diagnostic redaction; the router fans the set out from the booted context’s component metadata. Default noop: adapters without wire-path diagnostics render nothing to redact.