# Java 开发规范

/**
 * Copyright (c) 2019-${year} Meiyike Inc. to Present.
 * All Rights Reserved.
 *
 * This software is the confidential and proprietary information of Meiyike Inc. .
 * You shall not disclose such confidential information
 * and shall use it only in accordance with the terms of the license
 * agreement you entered into with www.meiyike.cn.
 *
 */

public class Answer {
  @_id
  @Oid
  private String id;
  private Long answerId;
  private String content;
}

@Repository
public class AnswerRepository {
	@Resource
	private MongoDatabase db;
	private MongoCollection<Answer> answers;

	@PostConstruct
	public void afterPropertiesSet() {
		answers = db.getCollection("hw.answer", Answer.class);
	}

  public void add(Answer answer) {
		answers.insertOne(answer);
	}
  ...
}

@Configuration
public static RedisConfig {
  @Bean
  public HessianRedisSerializer hessianRedisSerializer() {
    return new HessianRedisSerializer();
  }

  @Bean
  public RedisTemplate myRedisTemplate(RedisConnectionFactory redisConnectionFactory) {
    RedisTemplate<Object, Object> template = new RedisTemplate<>();
		template.setConnectionFactory(redisConnectionFactory);
    template.setsetDefaultSerializer(hessianRedisSerializer());
		return template;
  }
}

@EnableRabbit
@Configuration
public class RabbitConfig {

	@Bean
	public SimpleRabbitListenerContainerFactory rabbitListenerContainerFactory(
			SimpleRabbitListenerContainerFactoryConfigurer configurer, ConnectionFactory connectionFactory) {
		SimpleRabbitListenerContainerFactory factory = new SimpleRabbitListenerContainerFactory();
		configurer.configure(factory, connectionFactory);
		@SuppressWarnings("unchecked")
		FatalExceptionStrategy strategy = new YunguFatalExceptionStrategy();
		factory.setErrorHandler(new ConditionalRejectingErrorHandler(strategy));
		return factory;
	}

}

@Service
public class DeliveryService implements IDeliveryService {
  @Resource
	private RabbitTemplate rabbitTemplate;

  private void deliver(Delivery delivery) {
		rabbitTemplate.send("e.balance.delivery", null, JsonMessages.toMessage(delivery));
	}
}

@Component
public class DeliveryListener {

	private static final Logger LOG = LoggerFactory.getLogger(DeliveryListener.class);
	@Resource
	private IDeliveryService deliveryService;

	@RabbitListener(bindings = @QueueBinding(
			value = @Queue(value = "q.balance.delivery", durable = "true"),
			exchange = @Exchange(value = "e.balance.delivery", durable = "true")))
	public void handlerDelivery(Message msg) {
		Delivery payload = JsonMessages.parse(msg, Delivery.class);
		LOG.debug("received delivery {}", payload);
		// TODO
	}

}