@Override
    public <T> TypedMessageBuilder<T> newOutputMessage(String topicName, Schema<T> schema)
            throws PulsarClientException {
        MessageBuilderImpl<T> messageBuilder = new MessageBuilderImpl<>();
        TypedMessageBuilder<T> typedMessageBuilder;
        Producer<T> producer = getProducer(topicName, schema);
        if (schema != null) {
            typedMessageBuilder = producer.newMessage(schema);
        } else {
            typedMessageBuilder = producer.newMessage();
        }
        messageBuilder.setUnderlyingBuilder(typedMessageBuilder);
        return messageBuilder;
    }
@Test
    public void testPublishUsingDefaultSchema() throws Exception {
        context.newOutputMessage("sometopic", null).value("Somevalue").sendAsync();
    }