in javascript/showcase/showcase/showcase.js [135:161]
fn(context, message) {
// there is a specific builder for messages to be sent to a Kafka egress ...
context.send(
kafkaEgressMessage({
typename: "showcase/kafka-egress",
topic: "my-kafka-topic",
key: "my-key",
value: "my-utf8-value"
}));
// and a builder for kinesis
context.send(
kinesisEgressMessage({
typename: "showcase/kinesis-egress",
stream: "a_stream",
partitionKey: "akey", // can also be = context.self.id for example
value: "aValue"
}));
// if you've implemented your own egress (it is currently only possible to do with Java)
// then you can send it a message like this:
context.send(egressMessageBuilder({
target: "showecase/my-custom-egress",
value: {"name": "Bob"},
valueType: GreetJsonType
}));
}