Content resolution example with Spring Cloud Stream

Hi @dakotahnorth, welcome to the Community. You're going to need some way to deserialize the payload into your POJO. What format is your payload in? Spring can't just guess how to do this.

For example, if you look at the code generated by the Spring Cloud Stream generator for AsyncAPI docs, it uses Jackson @JsonInclude to build the POJOs from JSON schemas:

package com.example.app;

import com.fasterxml.jackson.annotation.JsonInclude;

@JsonInclude(JsonInclude.Include.NON_NULL)
public class PassengerInfo {

	public PassengerInfo () {
	}

	public PassengerInfo (
		String passengerAction, 
		String destination, 
		java.math.BigDecimal passengerId, 
		String tripId, 
		String vipStatus) {
		this.passengerAction = passengerAction;
		this.destination = destination;
		this.passengerId = passengerId;
		this.tripId = tripId;
		this.vipStatus = vipStatus;
	}

	private String passengerAction;
	private String destination;
	private java.math.BigDecimal passengerId;
	private String tripId;
	private String vipStatus;
	public String getPassengerAction() {
		return passengerAction;
	}

	public PassengerInfo setPassengerAction(String passengerAction) {
		this.passengerAction = passengerAction;
		return this;
	}


	public String getDestination() {
		return destination;
	}

	public PassengerInfo setDestination(String destination) {
		this.destination = destination;
		return this;
	}


	public java.math.BigDecimal getPassengerId() {
		return passengerId;
	}

	public PassengerInfo setPassengerId(java.math.BigDecimal passengerId) {
		this.passengerId = passengerId;
		return this;
	}


	public String getTripId() {
		return tripId;
	}

	public PassengerInfo setTripId(String tripId) {
		this.tripId = tripId;
		return this;
	}


	public String getVipStatus() {
		return vipStatus;
	}

	public PassengerInfo setVipStatus(String vipStatus) {
		this.vipStatus = vipStatus;
		return this;
	}

	public String toString() {
		return "PassengerInfo ["
		+ " passengerAction: " + passengerAction
		+ " destination: " + destination
		+ " passengerId: " + passengerId
		+ " tripId: " + tripId
		+ " vipStatus: " + vipStatus
		+ " ]";
	}
}