Spring AI MCP Batch Job Server

Spring AI MCP Batch Job Server

A Spring Boot Model Context Protocol (MCP) server that provides batch processing tools for financial transactions.

iAMSagar44

Research & Data
Visit Server

README

Spring AI MCP Batch Job Server

A Spring Boot Model Context Protocol (MCP) server that provides batch processing tools for financial transactions. This project showcases the Spring AI MCP Server Boot Starter capabilities with STDIO transport implementation, combined with Spring Batch for processing financial data.

Prerequisites

  • Java 21 or later
  • PostgreSQL database
  • Understanding of Spring Boot, Spring Batch, Spring AI and MCP concepts
  • OpenAI API key for AI-powered transaction categorization

About Spring AI MCP Server Boot Starter

The project uses Spring AI's MCP Server Boot Starter to expose batch processing operations as tools that can be consumed by AI assistants. It combines this with Spring Batch to process financial transaction data, categorize transactions using AI, and store them in a PostgreSQL database.

Tool Implementation

The project demonstrates how to implement and register MCP tools using Spring's dependency injection and auto-configuration:

@Service
public class BatchJobService {
    @Tool(description = "Triggers a batch job based on the provided file name.")
    public ResponseEntity<JobDetails> startJob(String fileName) {
        // Implementation
    }

    @Tool(description = "Restarts a failed job based on the job execution ID.")
    public ResponseEntity<?> restartJob(Long executionId) {
        // Implementation
    }

    @Tool(description = "Retrieves the status of a batch job based on the job execution ID.")
    public ResponseEntity<JobDetails> getJobStatus(Long executionId) {
        // Implementation
    }
}

Available Agents

  1. Start Job Agent

    • Triggers a batch job to process a financial transactions file
    • Requires the file name
    • Reads CSV files from the user's Downloads directory
    • Returns job execution details including ID and status
  2. Restart Job Agent

    • Restarts a failed job execution
    • Requires the job execution ID of the failed job
    • Returns the new job execution details
  3. Job Status Agent

    • Retrieves the current status of a job
    • Requires the job execution ID
    • Provides detailed execution information including start/end times
    • Useful for monitoring job progress

Processing Pipeline

The batch job processes financial transactions through multiple steps:

  1. File Movement Step

    • Moves the input file to a temporary location
    • Ensures file safety during processing
  2. Transaction Processing Step

    • Reads CSV files with transaction data
    • Filters and categorizes credit/debit transactions
    • Uses AI to categorize transactions by type
    • Writes processed data to PostgreSQL database
  3. Cleanup Step

    • Removes temporary files after processing
    • Ensures clean workspace for next execution

Configuration

Application Properties

# Required STDIO Configuration
spring.main.web-application-type=none
spring.main.banner-mode=off
logging.pattern.console=

# Server Configuration
spring.ai.mcp.server.enabled=true
spring.ai.mcp.server.stdio=true
spring.ai.mcp.server.name=batch-job-mcp

# Database Configuration
spring.datasource.url=jdbc:postgresql://localhost:5432/postgres
spring.datasource.username=postgres
spring.datasource.password=postgres
spring.batch.jdbc.initialize-schema=always

# OpenAI Configuration
spring.ai.openai.api-key=${OPENAI_API_KEY}
spring.ai.openai.chat.options.model=gpt-4o

Building and Running

The server uses STDIO transport mode and is typically started automatically by the client. To build the server jar:

./mvnw clean install

Client Integration

To use this batch processing server with Claude Desktop, add the following configuration to your Claude Desktop settings:

{
    "mcpServers": {
        "spring-ai-batch-mcp": {
            "command": "java",
            "args": [
                "-Dspring.ai.mcp.server.stdio=true",
                "-Dspring.main.web-application-type=none",
                "-Dlogging.pattern.console=",
                "-Dlogging.file.name=<log_path/batch-job-mcp-0.0.1-SNAPSHOT.log>",
                "-jar",
                "/absolute/path/to/batch-job-mcp-0.0.1-SNAPSHOT.jar"
            ],
            "env": {
                "OPENAI_API_KEY": "<YOUR_API_KEY>"
            }
        }
    }
}

Replace /absolute/path/to/ with the actual path to your built jar file.

Replace log_path with the actual path where you want the logs to be generated.

Database Schema

The application requires the following PostgreSQL tables:

  • financial_transaction: Main transactions table
  • credit_transactions: Credit transactions
  • credit_card_payments: Credit card payment transactions
  • categories: List of transaction categories

If the spring.profiles.active in the application.properties file is set to 'local', then these tables are automatically created.

The Spring Batch tables are automatically created when spring.batch.jdbc.initialize-schema=always.

Additional Resources

Recommended Servers

Crypto Price & Market Analysis MCP Server

Crypto Price & Market Analysis MCP Server

A Model Context Protocol (MCP) server that provides comprehensive cryptocurrency analysis using the CoinCap API. This server offers real-time price data, market analysis, and historical trends through an easy-to-use interface.

Featured
TypeScript
MCP PubMed Search

MCP PubMed Search

Server to search PubMed (PubMed is a free, online database that allows users to search for biomedical and life sciences literature). I have created on a day MCP came out but was on vacation, I saw someone post similar server in your DB, but figured to post mine.

Featured
Python
dbt Semantic Layer MCP Server

dbt Semantic Layer MCP Server

A server that enables querying the dbt Semantic Layer through natural language conversations with Claude Desktop and other AI assistants, allowing users to discover metrics, create queries, analyze data, and visualize results.

Featured
TypeScript
mixpanel

mixpanel

Connect to your Mixpanel data. Query events, retention, and funnel data from Mixpanel analytics.

Featured
TypeScript
Sequential Thinking MCP Server

Sequential Thinking MCP Server

This server facilitates structured problem-solving by breaking down complex issues into sequential steps, supporting revisions, and enabling multiple solution paths through full MCP integration.

Featured
Python
Nefino MCP Server

Nefino MCP Server

Provides large language models with access to news and information about renewable energy projects in Germany, allowing filtering by location, topic (solar, wind, hydrogen), and date range.

Official
Python
Vectorize

Vectorize

Vectorize MCP server for advanced retrieval, Private Deep Research, Anything-to-Markdown file extraction and text chunking.

Official
JavaScript
Mathematica Documentation MCP server

Mathematica Documentation MCP server

A server that provides access to Mathematica documentation through FastMCP, enabling users to retrieve function documentation and list package symbols from Wolfram Mathematica.

Local
Python
kb-mcp-server

kb-mcp-server

An MCP server aimed to be portable, local, easy and convenient to support semantic/graph based retrieval of txtai "all in one" embeddings database. Any txtai embeddings db in tar.gz form can be loaded

Local
Python
Research MCP Server

Research MCP Server

The server functions as an MCP server to interact with Notion for retrieving and creating survey data, integrating with the Claude Desktop Client for conducting and reviewing surveys.

Local
Python