以下是一个示例代码，用于处理AMQP RabbitMQ消费者被终止并且没有重新启动的问题：

import time
import pika

def callback(ch, method, properties, body):
    # 消费者的处理逻辑
    print("Received message:", body)

def on_open(connection):
    # 当连接建立时，创建一个新的channel
    connection.channel(on_open_callback=on_channel_open)

def on_channel_open(channel):
    # 当channel打开时，声明一个队列并开始消费
    channel.queue_declare(queue='my_queue', durable=True)
    channel.basic_consume(queue='my_queue', on_message_callback=callback)

def on_close(connection, reply_code, reply_text):
    # 当连接关闭时，等待一段时间后重新建立连接
    print("Connection closed. Reconnecting...")
    time.sleep(5)
    connect()

def connect():
    # 建立连接
    parameters = pika.ConnectionParameters('localhost')
    connection = pika.SelectConnection(parameters, on_open_callback=on_open, on_close_callback=on_close)
    connection.ioloop.start()

# 启动连接
connect()

在上述代码中，我们使用了pika库来处理RabbitMQ连接和消息消费。在on_open回调函数中，我们创建一个新的channel并声明一个队列，然后开始消费。在on_close回调函数中，我们等待一段时间后重新建立连接。通过这种方式，当消费者被终止时，它会尝试重新建立连接并继续消费消息。

请注意，上述代码只是一个示例，你需要根据自己的实际需求进行修改。另外，你还需要根据你的RabbitMQ服务器的配置进行相应的参数设置。