SampleRequestSourceAndResponseSink.siddhi

@Source(type = 'http-request', source.id='login-request', 
receiver.url="https://localhost:8280/analytics", 
@map(type='json', 
@attributes(messageId='trp:messageId', 
username='$.username', loginTime='$.loginTime', loginIp = '$.loginIp')))
define stream InputStream (
    messageId string,
    username string,
    loginIp string,
    loginTime long);
    
@sink(type='http-response', source.id='login-request', 
message.id='{{messageId}}', @map(type='json'))
define stream OutputStream (
    messageId string,
    username string,
    risk double);