Updated all state machine activities to pass the CancellationToken when calling any transport-related methods (publish, send, request, schedule, etc.)