MessageProducerService.groovy

package codes.recursive.barn.automation.service.streaming

import com.oracle.bmc.auth.ConfigFileAuthenticationDetailsProvider
import com.oracle.bmc.streaming.StreamClient
import com.oracle.bmc.streaming.model.PutMessagesDetails
import com.oracle.bmc.streaming.model.PutMessagesDetailsEntry
import com.oracle.bmc.streaming.requests.PutMessagesRequest
import groovy.util.logging.Slf4j

import javax.enterprise.context.ApplicationScoped
import java.nio.charset.Charset

@ApplicationScoped
@Slf4j
class MessageProducerService {
    String configFilePath
    String streamId
    StreamClient client

    MessageProducerService(configFilePath=System.getProperty("ociConfigPath"), streamId=System.getProperty("streamId")) {
        this.configFilePath = configFilePath
        this.streamId = streamId
        def provider =  new ConfigFileAuthenticationDetailsProvider(this.configFilePath, 'DEFAULT')
        def client = new StreamClient(provider)
        client.setRegion('us-phoenix-1')
        this.client = client
    }

    def send(String msg, String key=UUID.randomUUID().toString()) {
        try {
            def putMessageDetails = PutMessagesDetails.builder()
                .messages([
                    PutMessagesDetailsEntry.builder()
                        .key(key.getBytes(Charset.forName("UTF-8")))
                        .value(msg.getBytes(Charset.forName("UTF-8")))
                        .build()
                ])
                .build()
            def putMessageRequest = PutMessagesRequest.builder()
                .streamId(this.streamId)
                .putMessagesDetails(putMessageDetails)
                .build()
            client.putMessages(putMessageRequest)
        }
        catch(e) {
            log.error("An error occurred whilst sending message...")
            e.printStackTrace()
        }
        finally {
            //log.info("Send complete for message with key ${key}")
        }
    }

    def close() {
    }
}